ARTEMIS-3776 just my OCD applying aesthetic tweaks to recediveOW.groovy

apache · Apr 13, 2022 · ccfd4b7a62ea9e648aa15b8083285778cdaaeae9 · ccfd4b7
1 parent bc17acd
commit ccfd4b7a62ea9e648aa15b8083285778cdaaeae9
Showing 2 changed files with 19 additions and 19 deletions.
diff --git a/tests/compatibility-tests/src/main/resources/oldOpenWire/receiveOW.groovy b/tests/compatibility-tests/src/main/resources/oldOpenWire/receiveOW.groovy
@@ -18,29 +18,29 @@
 
 import org.apache.activemq.artemis.tests.compatibility.GroovyRun
 
-import javax.jms.Connection
 import javax.jms.MessageConsumer
-import java.util.Date;
-import java.util.UUID;
-import javax.jms.ConnectionFactory;
-import javax.jms.MessageProducer;
 import javax.jms.Queue;
 import javax.jms.Session;
 import javax.jms.TextMessage;
 import org.apache.activemq.ActiveMQConnectionFactory;
 
+{
+    final ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("failover:(tcp://localhost:61616)");
+    connection = cf.createConnection();
+    try {
 
-final ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("failover:(tcp://localhost:61616)");
-connection = cf.createConnection();
-final int numberOfMessages = Integer.parseInt(arg[0])
-final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-final Queue queue = session.createQueue("Test");
-final MessageConsumer consumer = session.createConsumer(queue)
-connection.start();
+        final int numberOfMessages = Integer.parseInt(arg[0])
+        final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        final Queue queue = session.createQueue("Test");
+        final MessageConsumer consumer = session.createConsumer(queue)
+        connection.start();
 
-for (int i = 0; i < numberOfMessages; i++) {
-    final TextMessage tm = (TextMessage)consumer.receive(1000);
-    GroovyRun.assertNotNull(tm)
-    GroovyRun.assertEquals("m" + i, tm.getText());
-}
-connection.close();
+        for (int i = 0; i < numberOfMessages; i++) {
+            final TextMessage tm = (TextMessage) consumer.receive(1000);
+            GroovyRun.assertNotNull(tm)
+            GroovyRun.assertEquals("m" + i, tm.getText());
+        }
+    } finally {
+        connection.close();
+    }
+}
diff --git a/tests/compatibility-tests/src/main/resources/oldOpenWire/sendCore.groovy b/tests/compatibility-tests/src/main/resources/oldOpenWire/sendCore.groovy
@@ -50,4 +50,4 @@ import org.apache.activemq.artemis.jms.client.ActiveMQJMSConnectionFactory;
     finally {
         if (c != null) c.close();
     }
-}
+}