You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2010/07/23 17:05:51 UTC

svn commit: r967122 - /activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/component/CamelEndpointLoader.java

Author: gtully
Date: Fri Jul 23 15:05:50 2010
New Revision: 967122

URL: http://svn.apache.org/viewvc?rev=967122&view=rev
Log:
fix compilation error with 2.4, endpoints is a lur cache of endpoints so they will disappear in time, really needs a new component api - list available endpoints - 2.5 wabol

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=967122&r1=967121&r2=967122&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 Fri Jul 23 15:05:50 2010
@@ -187,7 +187,9 @@ public class CamelEndpointLoader impleme
 
     protected void removeQueue(ActiveMQQueue queue) throws Exception {
         String queueUri = getQueueUri(queue);
-        camelContext.removeEndpoints(queueUri);
+        // lur cache of endpoints so they will disappear in time
+        // this feature needs a new component api - list available endpoints
+        //camelContext.removeEndpoints(queueUri);
     }
     
     protected void addTopic(ActiveMQTopic topic) throws Exception {
@@ -203,6 +205,8 @@ public class CamelEndpointLoader impleme
 
     protected void removeTopic(ActiveMQTopic topic) throws Exception {
         String topicUri = getTopicUri(topic);
-        camelContext.removeEndpoints(topicUri);
+        // lur cache of endpoints so they will disappear in time
+        // this feature needs a new component api - list available endpoints
+        //camelContext.removeEndpoints(topicUri);
     }
 }