svn commit: r481531 - /incubator/servicemix/trunk/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/jca/JcaProviderProcessor.java

[gnodet]

Author: gnodet
Date: Sat Dec  2 01:36:06 2006
New Revision: 481531

URL: http://svn.apache.org/viewvc?view=rev&rev=481531
Log:
SM-765: JCA provider should close the session after use

Modified:
    
incubator/servicemix/trunk/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/jca/JcaProviderProcessor.java

Modified: 
incubator/servicemix/trunk/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/jca/JcaProviderProcessor.java
URL: 
http://svn.apache.org/viewvc/incubator/servicemix/trunk/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/jca/JcaProviderProcessor.java?view=diff&rev=481531&r1=481530&r2=481531
==============================================================================
--- 
incubator/servicemix/trunk/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/jca/JcaProviderProcessor.java
 (original)
+++ 
incubator/servicemix/trunk/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/jca/JcaProviderProcessor.java
 Sat Dec  2 01:36:06 2006
@@ -81,9 +81,10 @@
             return;
         }
         Connection connection = null;
+        Session session = null;
         try {
             connection = connectionFactory.createConnection();
-            Session session = connection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
+            session = connection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
             if (destination == null) {
                 if (STYLE_QUEUE.equals(endpoint.getDestinationStyle())) {
                     destination = 
session.createQueue(endpoint.getJmsProviderDestinationName());
@@ -100,6 +101,9 @@
             exchange.setStatus(ExchangeStatus.DONE);
             channel.send(exchange);
         } finally {
+            if (session != null) {
+                session.close();
+            }
             if (connection != null) {
                 connection.close();
             }