From ccfd4b7a62ea9e648aa15b8083285778cdaaeae9 Mon Sep 17 00:00:00 2001
From: Clebert Suconic <clebertsuconic@apache.org>
Date: Wed, 13 Apr 2022 12:34:30 -0400
Subject: [PATCH] ARTEMIS-3776 just my OCD applying aesthetic tweaks to
 recediveOW.groovy

---
 .../resources/oldOpenWire/receiveOW.groovy    | 36 +++++++++----------
 .../resources/oldOpenWire/sendCore.groovy     |  2 +-
 2 files changed, 19 insertions(+), 19 deletions(-)

diff --git a/tests/compatibility-tests/src/main/resources/oldOpenWire/receiveOW.groovy b/tests/compatibility-tests/src/main/resources/oldOpenWire/receiveOW.groovy
index a2fe02f0e9..1922d0cce4 100644
--- 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();
\ No newline at end of file
+        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();
+    }
+}
\ No newline at end of file
diff --git a/tests/compatibility-tests/src/main/resources/oldOpenWire/sendCore.groovy b/tests/compatibility-tests/src/main/resources/oldOpenWire/sendCore.groovy
index 7d1e8ed591..a4841a8282 100644
--- 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();
     }
-}
+}
\ No newline at end of file