Break from reconnect

pixelib · Aug 25, 2023 · 85ddca6 · 85ddca6
1 parent 7511edb
commit 85ddca6
Showing 1 changed file with 16 additions and 3 deletions.
diff --git a/meteor-jedis/src/test/java/com/meteormsg/transport/redis/RedisTransportTest.java b/meteor-jedis/src/test/java/com/meteormsg/transport/redis/RedisTransportTest.java
@@ -13,6 +13,7 @@
 import java.util.List;
 
 import static org.junit.jupiter.api.Assertions.*;
+
 class RedisTransportTest {
 
     @Test
@@ -88,14 +89,20 @@ void subscribe_thenSuccess() throws IOException, InterruptedException {
         String topic = "test";
         String channel = "test_implementation";
 
+        List<AssertionFailedError> assertionErrors = new ArrayList<>();
+
         RedisServer server = RedisServer.newRedisServer()
                 .setOptions(ServiceOptions.withInterceptor((state, command, params) -> {
                     System.out.println("command: " + command);
                     System.out.println("params: " + params);
 
-//                    if ("subscribe".equals(command)) {
-//                        assertEquals(channel, params.get(0).toString(), "Channel name is not correct");
-//                    }
+                    try {
+                        if ("subscribe".equals(command)) {
+                            assertEquals(channel, params.get(0).toString(), "Channel name is not correct");
+                        }
+                    } catch (AssertionFailedError e) {
+                        assertionErrors.add(e);
+                    }
                     return MockExecutor.proceed(state, command, params);
                 }))
                 .start();
@@ -105,11 +112,17 @@ void subscribe_thenSuccess() throws IOException, InterruptedException {
 
         test.close();
         server.stop();
+
+        if (!assertionErrors.isEmpty()) {
+            throw assertionErrors.get(0);
+        }
     }
+
     @Test
     void getTopicName() {
 
     }
+
     @Test
     void close() {
     }