diff options
Diffstat (limited to 'sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/transport/TransportReferenceInterceptor.java')
-rw-r--r-- | sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/transport/TransportReferenceInterceptor.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/transport/TransportReferenceInterceptor.java b/sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/transport/TransportReferenceInterceptor.java index cafcd12cf2..3ed8021107 100644 --- a/sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/transport/TransportReferenceInterceptor.java +++ b/sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/transport/TransportReferenceInterceptor.java @@ -59,7 +59,8 @@ public class TransportReferenceInterceptor implements Interceptor { // get the jms context JMSBindingContext context = msg.getBindingContext(); - if (context.getReplyToDestination() == null) { + // [rfeng] For oneway operation as part of the bi-directional interface, the JMSReplyTo is present + if (context.getReplyToDestination() == null || msg.getOperation().isNonBlocking()) { responseMsg.setBody(null); } else { responseMsg = invokeResponse(msg); |