Fix testDisconnectClientWithoutClosingConnection (apache#516)

ascentstream · Jun 22, 2017 · c0ba223 · c0ba223
1 parent afd64df
commit c0ba223
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pulsar-broker/src/test/java/com/yahoo/pulsar/client/impl/BrokerClientIntegrationTest.java b/pulsar-broker/src/test/java/com/yahoo/pulsar/client/impl/BrokerClientIntegrationTest.java
@@ -197,9 +197,9 @@ public void testDisconnectClientWithoutClosingConnection() throws Exception {
 
         // unload ns-bundle2 as well
         pulsar.getNamespaceService().unloadNamespaceBundle((NamespaceBundle) bundle2);
-        verify(producer2, atLeastOnce()).connectionClosed(anyObject());
-
+        // let producer2 give some time to get disconnect signal and get disconencted
         Thread.sleep(200);
+        verify(producer2, atLeastOnce()).connectionClosed(anyObject());
 
         // producer1 must not be able to connect again
         assertTrue(prod1.getClientCnx() == null);