Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

CAMEL-5865 Honour replyToCacheLevelName, otherwise fallback to CACHE_…

…CONSUMER

git-svn-id: https://svn.apache.org/repos/asf/camel/trunk@1433750 13f79535-47bb-0310-9956-ffa450edef68
  • Loading branch information...
commit c6c72e538967379eb005049bcd8cbd206b0f90f1 1 parent ea82499
Raúl Kripalani raulk authored
8 components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java
View
@@ -120,9 +120,13 @@ protected AbstractMessageListenerContainer createListenerContainer() throws Exce
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";
Please sign in to comment.
Something went wrong with that request. Please try again.