You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2008/03/20 05:06:35 UTC
svn commit: r639152 -
/activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/requestor/Requestor.java
Author: ningjiang
Date: Wed Mar 19 21:06:34 2008
New Revision: 639152
URL: http://svn.apache.org/viewvc?rev=639152&view=rev
Log:
CAMEL-388 patch applied with thanks to Mikhail
Modified:
activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/requestor/Requestor.java
Modified: activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/requestor/Requestor.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/requestor/Requestor.java?rev=639152&r1=639151&r2=639152&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/requestor/Requestor.java (original)
+++ activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/requestor/Requestor.java Wed Mar 19 21:06:34 2008
@@ -37,6 +37,7 @@
import org.springframework.core.task.TaskExecutor;
import org.springframework.jms.listener.AbstractMessageListenerContainer;
import org.springframework.jms.listener.SimpleMessageListenerContainer;
+import org.springframework.jms.listener.SimpleMessageListenerContainer102;
import org.springframework.jms.support.destination.DestinationResolver;
/**
@@ -48,7 +49,7 @@
private AbstractMessageListenerContainer listenerContainer;
private TimeoutMap requestMap;
private Destination replyTo;
-
+
public Requestor(JmsConfiguration configuration, ScheduledExecutorService executorService) {
this.configuration = configuration;
requestMap = new DefaultTimeoutMap(executorService, configuration.getRequestMapPurgePollTimeMillis());
@@ -135,7 +136,8 @@
}
protected AbstractMessageListenerContainer createListenerContainer() {
- SimpleMessageListenerContainer answer = new SimpleMessageListenerContainer();
+ SimpleMessageListenerContainer answer = configuration.isUseVersion102() ?
+ new SimpleMessageListenerContainer102() : new SimpleMessageListenerContainer();
answer.setDestinationName("temporary");
answer.setDestinationResolver(new DestinationResolver() {