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

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

Author: estebanschifman
Date: 2007-01-22 08:07:53 -0500 (Mon, 22 Jan 2007)
New Revision: 8961

Modified:
   labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/couriers/JmsCourier.java
Log:
Fix JMS reconnect issue (JIRA JBESB-312)

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	2007-01-22 11:01:15 UTC (rev 8960)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/couriers/JmsCourier.java	2007-01-22 13:07:53 UTC (rev 8961)
@@ -28,6 +28,7 @@
 import java.util.List;
 
 import javax.jms.Connection;
+import javax.jms.ExceptionListener;
 import javax.jms.JMSException;
 import javax.jms.MessageConsumer;
 import javax.jms.MessageProducer;
@@ -304,6 +305,7 @@
 				}
 				else
 					throw new CourierException("Unknown destination type");
+			setConnExceptionListener();
 		}
 		catch (JMSException ex)
 		{
@@ -471,6 +473,7 @@
 				else
 					throw new CourierException("Unknown destination type");
 			}
+			setConnExceptionListener();
 		}
 		catch (JMSException ex)
 		{
@@ -488,7 +491,22 @@
 		}
 
 	} // ________________________________
+	
+	protected void setConnExceptionListener() throws JMSException
+	{
+		_jmsConnection.setExceptionListener
+		(new ExceptionListener()
+		{
+			public void onException(JMSException arg0) 
+			{
+				cleanup();
+				jmsConnectRetry(arg0);
+			}
+			
+		});
+	} //________________________________
 
+
 	long _sleepForRetries = 3000; // milliseconds
 
 	protected boolean _isReceiver;