X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=replicate%2Fmdsal-replicate-netty%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fmdsal%2Freplicate%2Fnetty%2FIntegrationTest.java;h=5f0a06b082f5751faadc781d75f20cc82beffd4f;hb=3dea95b1c0e3f6c1b241b936f90b11a736f1c2f2;hp=08bc369ce16841956b28dbdedfe9ca3cc1419cd6;hpb=bc96b8f75abdca0f7569af99238ba95391666301;p=mdsal.git

diff --git a/replicate/mdsal-replicate-netty/src/test/java/org/opendaylight/mdsal/replicate/netty/IntegrationTest.java b/replicate/mdsal-replicate-netty/src/test/java/org/opendaylight/mdsal/replicate/netty/IntegrationTest.java
index 08bc369ce1..5f0a06b082 100644
--- a/replicate/mdsal-replicate-netty/src/test/java/org/opendaylight/mdsal/replicate/netty/IntegrationTest.java
+++ b/replicate/mdsal-replicate-netty/src/test/java/org/opendaylight/mdsal/replicate/netty/IntegrationTest.java
@@ -81,7 +81,8 @@ public class IntegrationTest extends AbstractDataBrokerTest {
     @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);
 
@@ -95,7 +96,7 @@ public class IntegrationTest extends AbstractDataBrokerTest {
 
         // 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
@@ -126,7 +127,8 @@ public class IntegrationTest extends AbstractDataBrokerTest {
         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);
 
@@ -140,7 +142,7 @@ public class IntegrationTest extends AbstractDataBrokerTest {
 
         // 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