svn commit: r1071964 - /servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/AbstractJMSFlow.java

[jbonofre]

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);