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);
}
}