- void activate(final Config config) throws UnknownHostException {
- final InetAddress sourceAddress = InetAddress.getByName(config.sourceHost());
- final Duration reconnectDelay = Duration.ofMillis(config.reconnectDelayMillis());
- final Duration keepaliveInterval = Duration.ofSeconds(config.keepAliveIntervalSeconds());
-
- reg = createSink(bootstrapSupport, dataBroker, singletonService, config.enabled(), sourceAddress,
- config.sourcePort(), reconnectDelay, keepaliveInterval, config.maxMissedKeepalives());
+ public NettyReplicationSink(@Reference final BootstrapSupport bootstrapSupport,
+ @Reference final DOMDataBroker dataBroker,
+ @Reference final ClusterSingletonServiceProvider singletonService, final Config config)
+ throws UnknownHostException {
+ reg = createSink(bootstrapSupport, dataBroker, singletonService, config.enabled(),
+ InetAddress.getByName(config.sourceHost()),
+ config.sourcePort(), Duration.ofMillis(config.reconnectDelayMillis()),
+ Duration.ofSeconds(config.keepAliveIntervalSeconds()), config.maxMissedKeepalives());