| Commit in servicemix/base/src/main/java/org/servicemix/jbi/nmr/flow/jca on MAIN | |||
| JCAFlow.java | +3 | -3 | 1.2 -> 1.3 |
Missing a start on the connection for the jca flow
servicemix/base/src/main/java/org/servicemix/jbi/nmr/flow/jca
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);
}
}
}
