You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by jb...@apache.org on 2011/02/18 12:18:12 UTC
svn commit: r1071964 -
/servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/AbstractJMSFlow.java
Author: jbonofre
Date: Fri Feb 18 11:18:11 2011
New Revision: 1071964
URL: http://svn.apache.org/viewvc?rev=1071964&view=rev
Log:
[SM-1964] Fix JMS Flow with PooledConnection.
Modified:
servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/AbstractJMSFlow.java
Modified: servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/AbstractJMSFlow.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/AbstractJMSFlow.java?rev=1071964&r1=1071963&r2=1071964&view=diff
==============================================================================
--- servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/AbstractJMSFlow.java (original)
+++ servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/AbstractJMSFlow.java Fri Feb 18 11:18:11 2011
@@ -476,7 +476,7 @@ public abstract class AbstractJMSFlow ex
boolean useConnectionFromPool = (connectionFactory instanceof PooledConnectionFactory)
&& ((PooledConnectionFactory)connectionFactory).getMaxConnections() > 1;
if (useConnectionFromPool) {
- connectionFactory.createConnection();
+ cnx = connectionFactory.createConnection();
cnx.start();
}
@@ -493,11 +493,6 @@ public abstract class AbstractJMSFlow ex
queueProducer.send(msg);
} finally {
inboundSession.close();
- if (useConnectionFromPool) {
- // return connection to the pool
- cnx.stop();
- cnx.close();
- }
}
} catch (JMSException e) {
log.error("Failed to send exchange: " + me + " internal JMS Network", e);