Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@967122 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2010-07-23 15:05:50 +00:00
parent 21e641d496
commit 623da6ffab
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-camel/src/main/java/org/apache/activemq/camel/component/CamelEndpointLoader.java
View File

@ -187,7 +187,9 @@ public class CamelEndpointLoader implements CamelContextAware {
protected void removeQueue(ActiveMQQueue queue) throws Exception { protected void removeQueue(ActiveMQQueue queue) throws Exception {
String queueUri = getQueueUri(queue); 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 { protected void addTopic(ActiveMQTopic topic) throws Exception {
@ -203,6 +205,8 @@ public class CamelEndpointLoader implements CamelContextAware {
protected void removeTopic(ActiveMQTopic topic) throws Exception { protected void removeTopic(ActiveMQTopic topic) throws Exception {
String topicUri = getTopicUri(topic); 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);
} }
} }