[jboss-cvs] JBossAS SVN: r82607 - projects/ejb3/trunk/docs/tutorial/mdb/src/org/jboss/tutorial/mdb/client.

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

Author: jaikiran
Date: 2009-01-05 05:18:01 -0500 (Mon, 05 Jan 2009)
New Revision: 82607

Modified:
   projects/ejb3/trunk/docs/tutorial/mdb/src/org/jboss/tutorial/mdb/client/Client.java
Log:
Added a cleanup block to close the JMS connection

Modified: projects/ejb3/trunk/docs/tutorial/mdb/src/org/jboss/tutorial/mdb/client/Client.java
===================================================================
--- projects/ejb3/trunk/docs/tutorial/mdb/src/org/jboss/tutorial/mdb/client/Client.java	2009-01-05 10:17:03 UTC (rev 82606)
+++ projects/ejb3/trunk/docs/tutorial/mdb/src/org/jboss/tutorial/mdb/client/Client.java	2009-01-05 10:18:01 UTC (rev 82607)
@@ -36,23 +36,36 @@
       processMessage("queue/tutorial/example");
       processMessage("queue/tutorial/defaultedexample");
    }
-   
+
    private static void processMessage(String queueBinding) throws Exception
    {
+
       QueueConnection cnn = null;
       QueueSender sender = null;
       QueueSession session = null;
-      InitialContext ctx = new InitialContext();
-      Queue queue = (Queue) ctx.lookup(queueBinding);
-      QueueConnectionFactory factory = (QueueConnectionFactory) ctx.lookup("ConnectionFactory");
-      cnn = factory.createQueueConnection();
-      session = cnn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
+      try
+      {
+         InitialContext ctx = new InitialContext();
+         Queue queue = (Queue) ctx.lookup(queueBinding);
+         QueueConnectionFactory factory = (QueueConnectionFactory) ctx.lookup("ConnectionFactory");
+         cnn = factory.createQueueConnection();
+         session = cnn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
 
-      TextMessage msg = session.createTextMessage("Hello World");
+         TextMessage msg = session.createTextMessage("Hello World");
 
-      sender = session.createSender(queue);
-      sender.send(msg);
-      System.out.println("Message sent successfully to remote queue " + queueBinding);
+         sender = session.createSender(queue);
+         sender.send(msg);
+         System.out.println("Message sent successfully to remote queue " + queueBinding);
+      }
+      finally
+      {
+         //cleanup
+         if (cnn != null)
+         {
+            cnn.close();
+         }
 
+      }
+
    }
 }