[feature][connectors-v2][ActiveMQ] add ActiveMQ source connector

apache · Jan 24, 2025 · 9b58e76 · 9b58e76
1 parent 5bd1f29
commit 9b58e76
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...or-activemq-e2e/src/test/java/org/apache/seatunnel/e2e/connector/activemq/ActivemqIT.java b/...or-activemq-e2e/src/test/java/org/apache/seatunnel/e2e/connector/activemq/ActivemqIT.java
@@ -185,6 +185,9 @@ public void testActiveMQ(TestContainer container) throws Exception {
                                 new String(
                                         JSON_SERIALIZATION_SCHEMA.serialize(
                                                 TEST_DATASET.getValue().get(1)))));
+        if (messageConsumer != null) {
+            messageConsumer.close();
+        }
     }
 
     private static Pair<SeaTunnelRowType, List<SeaTunnelRow>> generateTestDataSet() {