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

TUSCANY-3969: add fix from JIRA as suggested by Jennifer Thompson and Greg Dritschler

Browse source 
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1199186 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
antelder 2011-11-08 11:00:57 +00:00
parent 53d14f7330
commit f933459139
1 changed files with 25 additions and 0 deletions

25
sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/RRBJMSBindingInvoker.java
View file

@ -208,6 +208,31 @@ public class RRBJMSBindingInvoker extends InterceptorAsyncImpl {
context.setRequestDestination(getRequestDestination(tuscanyMsg, session));
context.setReplyToDestination(getReplyToDestination(session));
Long ttl = jmsBinding.getOperationJMSTimeToLive(operationName);
if (ttl != null) {
context.setTimeToLive(ttl);
}
// For twoway operations, determine a request timeout.
// The SCA specs do not address how to do this. We use the following approach.
// - If JMSTimeToLive is specified, use double that value.
// Doubling is basically arbitrary. JMSTimeToLive expresses request
// transmission and queue time. Doubling it allows request execution
// and response delivery to take up to the same amount of time.
// Note that explicitly coding a JMSTimeToLive of 0 results in
// a message that doesn't expire and an indefinite wait.
// - If JMSTimeToLive is not specified, get the default request
// timeout from the JMS resource factory and simply use that for the
// request timeout and JMSTimeToLive value.
if (!operation.isNonBlocking()) {
if (ttl != null) {
context.setRequestTimeout(ttl * 2);
} else {
long timeout = jmsResourceFactory.getDefaultRequestTimeout();
context.setRequestTimeout(timeout);
context.setTimeToLive(timeout);
}
}
try {
tuscanyMsg = endpointReference.getBindingInvocationChain().getHeadInvoker().invoke(tuscanyMsg);