From 3e895c6e9549b48856598a8ea949e1e2d904732c Mon Sep 17 00:00:00 2001 From: "Timothy A. Bish" Date: Thu, 24 Feb 2011 21:25:08 +0000 Subject: [PATCH] fix for: https://issues.apache.org/jira/browse/AMQ-3139 git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1074300 13f79535-47bb-0310-9956-ffa450edef68 --- .../activemq/camel/component/CamelEndpointLoader.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/activemq-camel/src/main/java/org/apache/activemq/camel/component/CamelEndpointLoader.java b/activemq-camel/src/main/java/org/apache/activemq/camel/component/CamelEndpointLoader.java index 14c5cc4f0f..92049de5d5 100644 --- a/activemq-camel/src/main/java/org/apache/activemq/camel/component/CamelEndpointLoader.java +++ b/activemq-camel/src/main/java/org/apache/activemq/camel/component/CamelEndpointLoader.java @@ -43,7 +43,7 @@ import org.slf4j.LoggerFactory; /** * A helper bean which populates a {@link CamelContext} with ActiveMQ Queue endpoints * - * + * * @org.apache.xbean.XBean */ public class CamelEndpointLoader implements CamelContextAware { @@ -189,9 +189,9 @@ public class CamelEndpointLoader implements CamelContextAware { String queueUri = getQueueUri(queue); // lur cache of endpoints so they will disappear in time // this feature needs a new component api - list available endpoints - //camelContext.removeEndpoints(queueUri); + camelContext.removeEndpoints(queueUri); } - + protected void addTopic(ActiveMQTopic topic) throws Exception { String topicUri = getTopicUri(topic); ActiveMQComponent jmsComponent = getComponent(); @@ -207,6 +207,6 @@ public class CamelEndpointLoader implements CamelContextAware { String topicUri = getTopicUri(topic); // lur cache of endpoints so they will disappear in time // this feature needs a new component api - list available endpoints - //camelContext.removeEndpoints(topicUri); + camelContext.removeEndpoints(topicUri); } }