Commit in servicemix/base/src/main/java/org/servicemix/jbi/nmr/flow/jca on MAIN
JCAFlow.java+3-31.2 -> 1.3
Missing a start on the connection for the jca flow

servicemix/base/src/main/java/org/servicemix/jbi/nmr/flow/jca
JCAFlow.java 1.2 -> 1.3
diff -u -r1.2 -r1.3
--- JCAFlow.java	4 Oct 2005 08:24:46 -0000	1.2
+++ JCAFlow.java	4 Oct 2005 09:42:07 -0000	1.3
@@ -74,7 +74,7 @@
 /**
  * Use for message routing among a network containers. All routing/registration happens automatically
  * 
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
  */
 public class JCAFlow extends SedaFlow implements ConsumerAdvisoryEventListener, MessageListener {
     private static final Log log = LogFactory.getLog(JCAFlow.class);
@@ -241,6 +241,7 @@
         	
         	// Outbound broadcast
         	connection = ((ActiveMQResourceAdapter) resourceAdapter).makeConnection();
+        	connection.start();
         	broadcastTopic = new ActiveMQTopic(broadcastDestinationName);
             advisor = new ConsumerAdvisor(connection, broadcastTopic);
             advisor.addListener(this);
@@ -263,8 +264,7 @@
                 advisor.start();
             }
             catch (JMSException e) {
-                JBIException jbiEx = new JBIException("JMSException caught in start: " + e.getMessage());
-                throw jbiEx;
+                throw new JBIException("JMSException caught in start: " + e.getMessage(), e);
             }
         }
     }
CVSspam 0.2.8



Reply via email to