svn commit: r639152 - /activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/requestor/Requestor.java

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

svn commit: r639152 - /activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/requestor/Requestor.java

ningjiang
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() {