[jboss-cvs] JBossAS SVN: r77355 - trunk/testsuite/src/main/org/jboss/test/timer/ejb.

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

Author: jesper.pedersen
Date: 2008-08-22 07:31:21 -0400 (Fri, 22 Aug 2008)
New Revision: 77355

Modified:
   trunk/testsuite/src/main/org/jboss/test/timer/ejb/TimerMessageBean.java
Log:
[JBAS-5866] Always close session and sender

Modified: trunk/testsuite/src/main/org/jboss/test/timer/ejb/TimerMessageBean.java
===================================================================
--- trunk/testsuite/src/main/org/jboss/test/timer/ejb/TimerMessageBean.java	2008-08-22 11:26:15 UTC (rev 77354)
+++ trunk/testsuite/src/main/org/jboss/test/timer/ejb/TimerMessageBean.java	2008-08-22 11:31:21 UTC (rev 77355)
@@ -87,7 +87,7 @@
       try
       {
          ctx = new InitialContext();
-         QueueConnectionFactory qcf = (QueueConnectionFactory) ctx.lookup("java:comp/env/jms/QCF");
+         QueueConnectionFactory qcf = (QueueConnectionFactory) ctx.lookup("ConnectionFactory");
          qc = qcf.createQueueConnection();
       }
       catch (Exception e)
@@ -163,10 +163,11 @@
       throws JMSException
    {
       QueueSession qs = null;
+      QueueSender sender = null;
       try
       {
          qs = qc.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
-         QueueSender sender = qs.createSender(dest);
+         sender = qs.createSender(dest);
          TextMessage reply = qs.createTextMessage();
          reply.setText(msg + " : " + msgID);
          reply.setIntProperty("UNIQUE_ID", msgID);
@@ -175,14 +176,29 @@
       }
       finally
       {
-         try
+         if (sender != null)
          {
-            qs.close();
-            log.info("JBossMQ QueueSession Closed");
+            try
+            {
+               sender.close();
+               log.info("JBossMQ QueueSender Closed");
+            }
+            catch (JMSException e)
+            {
+               log.error("Failed to close queue sender", e);
+            }
          }
-         catch (JMSException e)
+         if (qs != null)
          {
-            log.error("Failed to close queue session", e);
+            try
+            {
+               qs.close();
+               log.info("JBossMQ QueueSession Closed");
+            }
+            catch (JMSException e)
+            {
+               log.error("Failed to close queue session", e);
+            }
          }
       }
    }