You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ra...@apache.org on 2013/01/16 00:56:33 UTC
svn commit: r1433750 - in /camel/trunk/components/camel-jms: ./
src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java
Author: raulk
Date: Tue Jan 15 23:56:33 2013
New Revision: 1433750
URL: http://svn.apache.org/viewvc?rev=1433750&view=rev
Log:
CAMEL-5865 Honour replyToCacheLevelName, otherwise fallback to CACHE_CONSUMER
Modified:
camel/trunk/components/camel-jms/ (props changed)
camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java
Propchange: camel/trunk/components/camel-jms/
------------------------------------------------------------------------------
--- svn:mergeinfo (added)
+++ svn:mergeinfo Tue Jan 15 23:56:33 2013
@@ -0,0 +1,2 @@
+/camel/branches/camel-2.10.x:1433746
+/camel/branches/camel-2.10.x/components/camel-jms:1433746
Modified: camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java?rev=1433750&r1=1433749&r2=1433750&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java (original)
+++ camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java Tue Jan 15 23:56:33 2013
@@ -120,9 +120,13 @@ public class TemporaryQueueReplyManager
answer.setMaxConcurrentConsumers(endpoint.getMaxConcurrentConsumers());
}
answer.setConnectionFactory(endpoint.getConnectionFactory());
- // we use CACHE_CONSUMER to cling to the consumer as long as we can, since we can only consume
+ // we use CACHE_CONSUMER by default to cling to the consumer as long as we can, since we can only consume
// msgs from the JMS Connection that created the temp destination in the first place
- answer.setCacheLevel(DefaultMessageListenerContainer.CACHE_CONSUMER);
+ if (endpoint.getReplyToCacheLevelName() != null) {
+ answer.setCacheLevelName(endpoint.getReplyToCacheLevelName());
+ } else {
+ answer.setCacheLevel(DefaultMessageListenerContainer.CACHE_CONSUMER);
+ }
String clientId = endpoint.getClientId();
if (clientId != null) {
clientId += ".CamelReplyManager";