package org.opendaylight.controller.remote.rpc;
import org.apache.pekko.actor.ActorRef;
-import org.apache.pekko.actor.ActorSystem;
import org.apache.pekko.actor.PoisonPill;
import org.opendaylight.controller.cluster.ActorSystemProvider;
import org.opendaylight.mdsal.dom.api.DOMActionProviderService;
@Reference final DOMActionProviderService actionProviderService,
@Reference final DOMActionService actionService, final Config config) {
LOG.info("Remote Operations service starting");
- final ActorSystem actorSystem = actorSystemProvider.getActorSystem();
- final RemoteOpsProviderConfig opsConfig = RemoteOpsProviderConfig.newInstance(actorSystem.name(),
- config.metricCapture(), config.boundedMailboxCapacity());
+ final var actorSystem = actorSystemProvider.getActorSystem();
+ final var opsConfig = new RemoteOpsProviderConfig.Builder(actorSystem.name())
+ .metricCaptureEnabled(config.metricCapture())
+ .mailboxCapacity(config.boundedMailboxCapacity())
+ .build();
opsManager = actorSystem.actorOf(OpsManager.props(rpcProviderService, rpcService, opsConfig,
actionProviderService, actionService), opsConfig.getRpcManagerName());
package org.opendaylight.controller.remote.rpc;
import com.typesafe.config.Config;
-import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
import java.util.concurrent.TimeUnit;
import org.apache.pekko.util.Timeout;
import org.opendaylight.controller.cluster.common.actor.CommonConfig;
return cachedGossipTickInterval;
}
- /**
- * This is called via blueprint xml as the builder pattern can't be used.
- */
- @SuppressFBWarnings(value = "BC_UNCONFIRMED_CAST_OF_RETURN_VALUE",
- justification = "Findbugs flags this as an unconfirmed cast of return value but the build method clearly "
- + "returns RemoteOpsProviderConfig. Perhaps it's confused b/c the build method is overloaded and "
- + "and differs in return type from the base class.")
- public static RemoteOpsProviderConfig newInstance(final String actorSystemName, final boolean metricCaptureEnabled,
- final int mailboxCapacity) {
- return new Builder(actorSystemName).metricCaptureEnabled(metricCaptureEnabled)
- .mailboxCapacity(mailboxCapacity).build();
- }
-
public static class Builder extends CommonConfig.Builder<Builder> {
-
public Builder(final String actorSystemName) {
super(actorSystemName);