import io.netty.util.Timer;
import java.time.Duration;
import java.util.concurrent.Executor;
-import java.util.concurrent.ScheduledExecutorService;
import org.eclipse.jdt.annotation.NonNull;
import org.opendaylight.mdsal.binding.api.DataBroker;
import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider;
private final InstanceIdentifier<Node> instanceIdentifier;
private final Node node;
private final Timer timer;
- private final ScheduledExecutorService keepaliveExecutor;
private final Executor processingExecutor;
private final ActorSystem actorSystem;
private final NetconfClientFactory netconfClientFactory;
instanceIdentifier = builder.getInstanceIdentifier();
node = builder.getNode();
timer = builder.getTimer();
- keepaliveExecutor = builder.getKeepaliveExecutor();
processingExecutor = builder.getProcessingExecutor();
actorSystem = builder.getActorSystem();
netconfClientFactory = builder.getNetconfClientFactory();
return processingExecutor;
}
- public ScheduledExecutorService getKeepaliveExecutor() {
- return keepaliveExecutor;
- }
-
public Timer getTimer() {
return timer;
}
private InstanceIdentifier<Node> instanceIdentifier;
private Node node;
private Timer timer;
- private ScheduledExecutorService keepaliveExecutor;
private Executor processingExecutor;
private ActorSystem actorSystem;
private String topologyId;
return this;
}
- ScheduledExecutorService getKeepaliveExecutor() {
- return keepaliveExecutor;
- }
-
- public Builder setKeepaliveExecutor(final ScheduledExecutorService keepaliveExecutor) {
- this.keepaliveExecutor = keepaliveExecutor;
- return this;
- }
-
Executor getProcessingExecutor() {
return processingExecutor;
}