ns

belaban · Jun 21, 2023 · f434156 · f434156
1 parent 64a0ea1
commit f434156
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/tests/junit/org/jgroups/tests/ConcurrentCloseTest.java b/tests/junit/org/jgroups/tests/ConcurrentCloseTest.java
@@ -20,9 +20,11 @@ public class ConcurrentCloseTest extends ChannelTestBase {
     /** 2 channels, both call Channel.close() at exactly the same time */
     public void testConcurrentClose() throws Exception {
         final String GROUP="ConcurrentCloseTest";
-        a=createChannel().name("A").setReceiver(new MyReceiver("A")).connect(GROUP);
-        b=createChannel().name("B").setReceiver(new MyReceiver("B")).connect(GROUP);
+        a=createChannel().name("A").setReceiver(new MyReceiver("A"));
+        b=createChannel().name("B").setReceiver(new MyReceiver("B"));
         makeUnique(a,b);
+        a.connect(GROUP);
+        b.connect(GROUP);
         Util.waitUntilAllChannelsHaveSameView(10000, 1000, a,b);
 
         CyclicBarrier barrier=new CyclicBarrier(3);