@Test
public void testSourceToSink() throws InterruptedException, ExecutionException {
// Make sure to start source...
- final Registration source = NettyReplication.createSource(support, getDomBroker(), css, true, TEST_PORT);
+ final Registration source = NettyReplication.createSource(support, getDomBroker(), css, true, TEST_PORT,
+ Duration.ZERO, 5);
// ... and give it some time start up and open up the port
Thread.sleep(1000);
// Kick of the sink ...
final Registration sink = NettyReplication.createSink(support, sinkBroker, css, true,
- Inet4Address.getLoopbackAddress(), TEST_PORT, Duration.ZERO, Duration.ZERO);
+ Inet4Address.getLoopbackAddress(), TEST_PORT, Duration.ZERO, Duration.ZERO, 3);
// ... and sync on it starting up
// verify the connection was established and MSG_EMPTY_DATA was transferred
generateModification(getDataBroker(), deltaCount);
// Make sure to start source...
- final Registration source = NettyReplication.createSource(support, getDomBroker(), css, true, TEST_PORT);
+ final Registration source = NettyReplication.createSource(support, getDomBroker(), css, true, TEST_PORT,
+ Duration.ZERO, 5);
// ... and give it some time start up and open up the port
Thread.sleep(1000);
// Kick of the sink ...
final Registration sink = NettyReplication.createSink(support, sinkBroker, css, true,
- Inet4Address.getLoopbackAddress(), TEST_PORT, Duration.ZERO, Duration.ZERO);
+ Inet4Address.getLoopbackAddress(), TEST_PORT, Duration.ZERO, Duration.ZERO, 3);
// ... and sync on it starting up
// verify the connection was established and MSG_EMPTY_DATA was transferred