activemq-commits mailing list archives

Author: tabish
Date: Thu Feb 24 21:25:08 2011
New Revision: 1074300

URL: http://svn.apache.org/viewvc?rev=1074300&view=rev
Log:
fix for: https://issues.apache.org/jira/browse/AMQ-3139

Modified:
    activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/component/CamelEndpointLoader.java

Modified: activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/component/CamelEndpointLoader.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/component/CamelEndpointLoader.java?rev=1074300&r1=1074299&r2=1074300&view=diff
==============================================================================
--- activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/component/CamelEndpointLoader.java
(original)
+++ activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/component/CamelEndpointLoader.java
Thu Feb 24 21:25:08 2011
@@ -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 impleme
         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 impleme
         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);
     }
 }