org.apache.activemq.camel.component
Class CamelEndpointLoader
java.lang.Object
org.apache.activemq.camel.component.CamelEndpointLoader
- All Implemented Interfaces:
- org.apache.camel.CamelContextAware
public class CamelEndpointLoader
- extends Object
- implements org.apache.camel.CamelContextAware
A helper bean which populates a CamelContext
with ActiveMQ Queue endpoints
- Version:
- $Revision: 1.1 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CamelEndpointLoader
public CamelEndpointLoader()
CamelEndpointLoader
public CamelEndpointLoader(org.apache.camel.CamelContext camelContext)
afterPropertiesSet
@PostConstruct
public void afterPropertiesSet()
throws Exception
- Throws:
Exception
destroy
@PreDestroy
public void destroy()
throws Exception
- Throws:
Exception
getCamelContext
public org.apache.camel.CamelContext getCamelContext()
- Specified by:
getCamelContext
in interface org.apache.camel.CamelContextAware
setCamelContext
public void setCamelContext(org.apache.camel.CamelContext camelContext)
- Specified by:
setCamelContext
in interface org.apache.camel.CamelContextAware
getConnection
public EnhancedConnection getConnection()
getConnectionFactory
public ConnectionFactory getConnectionFactory()
setConnectionFactory
public void setConnectionFactory(ConnectionFactory connectionFactory)
getComponent
public ActiveMQComponent getComponent()
setComponent
public void setComponent(ActiveMQComponent component)
addQueue
protected void addQueue(ActiveMQQueue queue)
throws Exception
- Throws:
Exception
getQueueUri
protected String getQueueUri(ActiveMQQueue queue)
removeQueue
protected void removeQueue(ActiveMQQueue queue)
throws Exception
- Throws:
Exception
addTopic
protected void addTopic(ActiveMQTopic topic)
throws Exception
- Throws:
Exception
getTopicUri
protected String getTopicUri(ActiveMQTopic topic)
removeTopic
protected void removeTopic(ActiveMQTopic topic)
throws Exception
- Throws:
Exception
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.