[jboss-svn-commits] JBL Code SVN: r8543 - labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/couriers

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

Author: estebanschifman
Date: 2006-12-22 08:55:27 -0500 (Fri, 22 Dec 2006)
New Revision: 8543

Modified:
   labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/couriers/JmsCourier.java
Log:
Add pause between connection retries.  Make exception and logger messages more explicit

Modified: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/couriers/JmsCourier.java
===================================================================
--- labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/couriers/JmsCourier.java	2006-12-22 13:54:12 UTC (rev 8542)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/couriers/JmsCourier.java	2006-12-22 13:55:27 UTC (rev 8543)
@@ -246,7 +246,12 @@
 			throw new IllegalArgumentException("Timeout millis must be > 0");
 		if (null==_messageConsumer)
 			try {  createMessageConsumer();}
-			catch (Exception e) {throw new CourierException(e); }
+			catch (Exception e) 
+			{
+				try { Thread.sleep(1000); }
+				catch (InterruptedException eI) {/* OK do nothing */}
+				throw new CourierException("Unable to create Message Consumer", e); 
+			}
 		
 	    javax.jms.Message jmsMessage = null;
 		while (null!=_messageConsumer)
@@ -303,7 +308,11 @@
         if (Util.isNullString(sJndiPkgPrefix))
         	sJndiPkgPrefix = NamingContext.JBOSS_URL_PKG_PREFIX;
         Context oJndiCtx = NamingContext.getServerContext(sJndiURL, sJndiConnectionFactory, sJndiPkgPrefix);
+        if (null==oJndiCtx)
+        	throw new Exception("Unable fo obtain jndi context <"+sJndiURL
+        			+","+sJndiConnectionFactory+","+sJndiPkgPrefix+">");
 
+
         String sFactoryClass = _epr.getConnectionFactory();
         if (Util.isNullString(sFactoryClass))
         	sFactoryClass = "ConnectionFactory";