You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2009/09/14 13:26:41 UTC
svn commit: r814584 - in /camel/trunk/components/camel-jms/src:
main/java/org/apache/camel/component/jms/JmsEndpoint.java
test/java/org/apache/camel/component/jms/issues/JmsSendToAlotOfDestinationWithSameEndpointTest.java
Author: davsclaus
Date: Mon Sep 14 11:26:41 2009
New Revision: 814584
URL: http://svn.apache.org/viewvc?rev=814584&view=rev
Log:
CAMEL-2011: JmsEndpoint is now singleton.
Modified:
camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsSendToAlotOfDestinationWithSameEndpointTest.java
Modified: camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java?rev=814584&r1=814583&r2=814584&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java (original)
+++ camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java Mon Sep 14 11:26:41 2009
@@ -305,8 +305,9 @@
this.selector = selector;
}
+ @ManagedAttribute
public boolean isSingleton() {
- return false;
+ return true;
}
public synchronized Requestor getRequestor() throws Exception {
Modified: camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsSendToAlotOfDestinationWithSameEndpointTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsSendToAlotOfDestinationWithSameEndpointTest.java?rev=814584&r1=814583&r2=814584&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsSendToAlotOfDestinationWithSameEndpointTest.java (original)
+++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsSendToAlotOfDestinationWithSameEndpointTest.java Mon Sep 14 11:26:41 2009
@@ -47,7 +47,6 @@
// use the same endpoint but provide a header with the dynamic queue we send to
// this allows us to reuse endpoints and not create a new endpoint for each and every jms queue
// we send to
- Thread.sleep(50);
if (i > 0 && i % 50 == 0) {
LOG.info("Send " + i + " messages so far");
}