svn commit: r1199803 - in /camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply: PersistentQueueReplyManager.java TemporaryQueueReplyManager.java

[davsclaus]

Author: davsclaus
Date: Wed Nov  9 15:40:28 2011
New Revision: 1199803

URL: http://svn.apache.org/viewvc?rev=1199803&view=rev
Log:
CAMEL-4651: Setup a bean name on DMLC in reply manager so it has a Camel 
related thread name

Modified:
    
camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/PersistentQueueReplyManager.java
    
camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java

Modified: 
camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/PersistentQueueReplyManager.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/PersistentQueueReplyManager.java?rev=1199803&r1=1199802&r2=1199803&view=diff
==============================================================================
--- 
camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/PersistentQueueReplyManager.java
 (original)
+++ 
camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/PersistentQueueReplyManager.java
 Wed Nov  9 15:40:28 2011
@@ -154,6 +154,7 @@ public class PersistentQueueReplyManager
         answer.setPubSubDomain(false);
         answer.setSubscriptionDurable(false);
         answer.setConcurrentConsumers(1);
+        answer.setMaxConcurrentConsumers(1);
         answer.setConnectionFactory(endpoint.getConnectionFactory());
         String clientId = endpoint.getClientId();
         if (clientId != null) {
@@ -181,6 +182,11 @@ public class PersistentQueueReplyManager
         }
         // do not use a task executor for reply as we are are always a single 
threaded task
 
+        // setup a bean name which is used ny Spring JMS as the thread name
+        String name = "PersistentQueueReplyManager[" + 
answer.getDestinationName() + "]";
+        name = 
endpoint.getCamelContext().getExecutorServiceManager().resolveThreadName(name);
+        answer.setBeanName(name);
+
         return answer;
     }
 

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=1199803&r1=1199802&r2=1199803&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
 Wed Nov  9 15:40:28 2011
@@ -96,6 +96,7 @@ public class TemporaryQueueReplyManager 
         answer.setPubSubDomain(false);
         answer.setSubscriptionDurable(false);
         answer.setConcurrentConsumers(1);
+        answer.setMaxConcurrentConsumers(1);
         answer.setConnectionFactory(endpoint.getConnectionFactory());
         String clientId = endpoint.getClientId();
         if (clientId != null) {
@@ -121,6 +122,11 @@ public class TemporaryQueueReplyManager 
         }
         // do not use a task executor for reply as we are are always a single 
threaded task
 
+        // setup a bean name which is used ny Spring JMS as the thread name
+        String name = "TemporaryQueueReplyManager[" + 
answer.getDestinationName() + "]";
+        name = 
endpoint.getCamelContext().getExecutorServiceManager().resolveThreadName(name);
+        answer.setBeanName(name);
+
         return answer;
     }