2 * Copyright (c) 2020 PANTHEON.tech, s.r.o. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.controller.remote.rpc;
10 import akka.actor.ActorRef;
11 import akka.actor.ActorSystem;
12 import akka.actor.PoisonPill;
13 import org.opendaylight.controller.cluster.ActorSystemProvider;
14 import org.opendaylight.mdsal.dom.api.DOMActionProviderService;
15 import org.opendaylight.mdsal.dom.api.DOMActionService;
16 import org.opendaylight.mdsal.dom.api.DOMRpcProviderService;
17 import org.opendaylight.mdsal.dom.api.DOMRpcService;
18 import org.osgi.service.component.annotations.Activate;
19 import org.osgi.service.component.annotations.Component;
20 import org.osgi.service.component.annotations.Deactivate;
21 import org.osgi.service.component.annotations.Reference;
22 import org.osgi.service.metatype.annotations.AttributeDefinition;
23 import org.osgi.service.metatype.annotations.Designate;
24 import org.osgi.service.metatype.annotations.ObjectClassDefinition;
25 import org.slf4j.Logger;
26 import org.slf4j.LoggerFactory;
28 @Component(configurationPid = "org.opendaylight.controller.remoterpc")
29 @Designate(ocd = OSGiRemoteOpsProvider.Config.class)
30 public final class OSGiRemoteOpsProvider {
31 @ObjectClassDefinition()
32 public @interface Config {
33 @AttributeDefinition(name = "enable-metric-capture")
34 boolean metricCapture() default true;
35 @AttributeDefinition(name = "bounded-mailbox-capacity")
36 int boundedMailboxCapacity() default 1000;
39 private static final Logger LOG = LoggerFactory.getLogger(OSGiRemoteOpsProvider.class);
41 private ActorRef opsManager;
44 public OSGiRemoteOpsProvider(@Reference final ActorSystemProvider actorSystemProvider,
45 @Reference final DOMRpcProviderService rpcProviderService, @Reference final DOMRpcService rpcService,
46 @Reference final DOMActionProviderService actionProviderService,
47 @Reference final DOMActionService actionService, final Config config) {
48 LOG.info("Remote Operations service starting");
49 final ActorSystem actorSystem = actorSystemProvider.getActorSystem();
50 final RemoteOpsProviderConfig opsConfig = RemoteOpsProviderConfig.newInstance(actorSystem.name(),
51 config.metricCapture(), config.boundedMailboxCapacity());
53 opsManager = actorSystem.actorOf(OpsManager.props(rpcProviderService, rpcService, opsConfig,
54 actionProviderService, actionService), opsConfig.getRpcManagerName());
55 LOG.debug("Ops Manager started at {}", opsManager);
56 LOG.info("Remote Operations service started");
61 LOG.info("Remote Operations service stopping");
62 LOG.debug("Stopping Ops Manager at {}", opsManager);
63 opsManager.tell(PoisonPill.getInstance(), ActorRef.noSender());
65 LOG.info("Remote Operations services stopped");