import akka.util.Timeout;
import com.typesafe.config.Config;
+import java.util.concurrent.TimeUnit;
import org.opendaylight.controller.cluster.common.actor.CommonConfig;
import scala.concurrent.duration.FiniteDuration;
-import java.util.concurrent.TimeUnit;
-
/**
*/
public class RemoteRpcProviderConfig extends CommonConfig {
return cachedGossipTickInterval;
}
+ /**
+ * This is called via blueprint xml as the builder pattern can't be used.
+ */
+ public static RemoteRpcProviderConfig newInstance(String actorSystemName, boolean metricCaptureEnabled,
+ int mailboxCapacity) {
+ return new Builder(actorSystemName).metricCaptureEnabled(metricCaptureEnabled).
+ mailboxCapacity(mailboxCapacity).build();
+ }
+
public static class Builder extends CommonConfig.Builder<Builder>{
public Builder(String actorSystemName){
}
+ public Builder gossipTickInterval(String interval) {
+ configHolder.put(TAG_GOSSIP_TICK_INTERVAL, interval);
+ return this;
+ }
+
+ @Override
public RemoteRpcProviderConfig build(){
return new RemoteRpcProviderConfig(merge());
}