You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2006/12/02 10:36:07 UTC
svn commit: r481531 -
/incubator/servicemix/trunk/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/jca/JcaProviderProcessor.java
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();
}