archive/apache-tuscany
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge revision 980735 from trunk into the 1.6.1 branch

Browse source 
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@988721 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
nash 2010-08-24 20:45:27 +00:00
parent ee5141ec4c
commit cef9c8bdbc
1 changed files with 3 additions and 2 deletions

5
sca-java-1.x/branches/sca-java-1.6.1/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/transport/TransportServiceInterceptor.java
View file

@ -115,6 +115,7 @@ public class TransportServiceInterceptor implements Interceptor {
}
public Message invokeResponse(Message msg) {
JMSBindingContext context = msg.getBindingContext();
try {
//if operation is oneway, return back.
@ -123,7 +124,6 @@ public class TransportServiceInterceptor implements Interceptor {
return msg;
}
JMSBindingContext context = msg.getBindingContext();
Session session = context.getJmsResponseSession();
javax.jms.Message requestJMSMsg = context.getJmsMsg();
javax.jms.Message responseJMSMsg = msg.getBody();
@ -168,12 +168,13 @@ public class TransportServiceInterceptor implements Interceptor {
producer.send((javax.jms.Message)msg.getBody());
producer.close();
context.closeJmsResponseSession();
return msg;
} catch (JMSException e) {
throw new JMSBindingException(e);
} finally {
context.closeJmsResponseSession();
}
}