camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r1199803 - in /camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply: PersistentQueueReplyManager.java TemporaryQueueReplyManager.java
Date Wed, 09 Nov 2011 15:40:29 GMT
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;
     }
 



Mime
View raw message