[jboss-svn-commits] JBoss Common SVN: r4364 - arquillian/trunk/examples/junit/src/test/java/com/acme/jms.

[jboss-svn-commits at lists.jboss.org]

Author: aslak
Date: 2010-05-07 15:39:26 -0400 (Fri, 07 May 2010)
New Revision: 4364

Modified:
   arquillian/trunk/examples/junit/src/test/java/com/acme/jms/InjectionTestCase.java
Log:
ARQ-133 fixed JMS Connection leak in TestCase


Modified: arquillian/trunk/examples/junit/src/test/java/com/acme/jms/InjectionTestCase.java
===================================================================
--- arquillian/trunk/examples/junit/src/test/java/com/acme/jms/InjectionTestCase.java	2010-05-07 19:38:03 UTC (rev 4363)
+++ arquillian/trunk/examples/junit/src/test/java/com/acme/jms/InjectionTestCase.java	2010-05-07 19:39:26 UTC (rev 4364)
@@ -64,18 +64,26 @@
       
       String messageBody = "ping";
       
-      Connection connection = factory.createConnection();
-      Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-      QueueRequestor requestor = new QueueRequestor((QueueSession)session, dlq);
+      Connection connection = null;
+      try
+      {
+         connection = factory.createConnection();
+         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+         QueueRequestor requestor = new QueueRequestor((QueueSession)session, dlq);
 
-      connection.start();
-      
-      Message request = session.createTextMessage(messageBody);
-      Message response = requestor.request(request, 5000);
-      
-      Assert.assertEquals(
-            "Should have responded with same message",
-            messageBody,
-            ((TextMessage)response).getText());
+         connection.start();
+         
+         Message request = session.createTextMessage(messageBody);
+         Message response = requestor.request(request, 5000);
+         
+         Assert.assertEquals(
+               "Should have responded with same message",
+               messageBody,
+               ((TextMessage)response).getText());
+      }
+      finally
+      {
+         connection.close();
+      }
    }
 }