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