[jboss-svn-commits] JBL Code SVN: r16530 - in labs/jbossesb/trunk/product/samples/quickstarts: bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/test and 1 other directory.

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

Author: tfennelly
Date: 2007-11-12 06:01:14 -0500 (Mon, 12 Nov 2007)
New Revision: 16530

Modified:
   labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration2/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration2/test/SendJMSMessageDeploy.java
   labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/test/SendJMSMessage.java
Log:
http://jira.jboss.com/jira/browse/JBESB-1212

Modified: labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration2/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration2/test/SendJMSMessageDeploy.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration2/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration2/test/SendJMSMessageDeploy.java	2007-11-12 09:56:13 UTC (rev 16529)
+++ labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration2/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration2/test/SendJMSMessageDeploy.java	2007-11-12 11:01:14 UTC (rev 16530)
@@ -61,9 +61,21 @@
     
     public void stop() throws JMSException 
     { 
-        conn.stop();
-        session.close();
-        conn.close();
+        try {
+            if(conn != null) {
+                conn.stop();
+            }
+        } finally {
+            try {
+                if(session != null) {
+                    session.close();
+                }
+            } finally {
+                if(conn != null) {
+                    conn.close();
+                }
+            }
+        }
     }
     
     public void sendAMessage(String msg) throws JMSException {
@@ -76,12 +88,19 @@
        
     
     public static void main(String args[]) throws Exception
-    {               
-      SendJMSMessageDeploy sm = new SendJMSMessageDeploy();
-      sm.setupConnection();
-      sm.sendAMessage(args[0]); 
-      sm.stop();
-      
+    {
+        SendJMSMessageDeploy sm = new SendJMSMessageDeploy();
+        try {
+            sm.setupConnection();
+            sm.sendAMessage(args[0]);
+        } catch (Exception e) {
+            System.out.println("\n**** Failed to send message to JMS Destination '" + args[0] + "'.  " +
+                               "\n**** Your JMS Provider (e.g. your JBoss ESB/App Server) may not be running, or the JMS Destination may not be deployed." +
+                               "\n**** Exception: " + e.getMessage());
+        } finally {
+            sm.stop();
+        }
+
     }
     
 }

Modified: labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/test/SendJMSMessage.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/test/SendJMSMessage.java	2007-11-12 09:56:13 UTC (rev 16529)
+++ labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/test/SendJMSMessage.java	2007-11-12 11:01:14 UTC (rev 16530)
@@ -20,13 +20,9 @@
  */
 package org.jboss.soa.esb.samples.quickstart.bpm_orchestration3.test;
 
-import javax.jms.JMSException;
-import javax.jms.ObjectMessage;
-import javax.jms.Queue;
-import javax.jms.QueueConnection;
-import javax.jms.QueueConnectionFactory;
-import javax.jms.QueueSender;
-import javax.jms.QueueSession;
+import org.jgroups.protocols.JMS;
+
+import javax.jms.*;
 import javax.naming.InitialContext;
 import javax.naming.NamingException;
 
@@ -48,10 +44,22 @@
     }
     
     public void stop() throws JMSException 
-    { 
-        conn.stop();
-        session.close();
-        conn.close();
+    {
+        try {
+            if(conn != null) {
+                conn.stop();
+            }
+        } finally {
+            try {
+                if(session != null) {
+                    session.close();
+                }
+            } finally {
+                if(conn != null) {
+                    conn.close();
+                }
+            }
+        }
     }
     
     public void sendAMessage(String msg, String tokenID) throws JMSException {
@@ -66,20 +74,22 @@
        
     
     public static void main(String args[]) throws Exception
-    {        	    	
-    	SendJMSMessage sm = new SendJMSMessage();
-    	try {
-    		sm.setupConnection(args[0]);
-    		if (args.length < 3)
-    			sm.sendAMessage(args[1],null); 
-    		else
-    			sm.sendAMessage(args[1],args[2]); 
-    	} catch (Exception e) {
-    		System.out.println(e);
-      } finally {
-    	  sm.stop();
-    	}  
-    	
+    {
+        SendJMSMessage sm = new SendJMSMessage();
+        try {
+            sm.setupConnection(args[0]);
+            if (args.length < 3)
+                sm.sendAMessage(args[1], null);
+            else
+                sm.sendAMessage(args[1], args[2]);
+        } catch (Exception e) {
+            System.out.println("\n**** Failed to send message to JMS Destination '" + args[0] + "'.  " +
+                               "\n**** Your JMS Provider (e.g. your JBoss ESB/App Server) may not be running, or the JMS Destination may not be deployed." +
+                               "\n**** Exception: " + e.getMessage());
+        } finally {
+            sm.stop();
+        }
+
     }
     
 }
\ No newline at end of file