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

fix for: https://issues.apache.org/jira/browse/AMQ-3139 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1074300 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2011-02-24 21:25:08 +00:00
parent a5fc6dd999
commit 3e895c6e95
1 changed files with 4 additions and 4 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

@ -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 implements CamelContextAware {
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 implements CamelContextAware {
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);
}
}