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

Constructor Summary

CamelEndpointLoader()

CamelEndpointLoader(org.apache.camel.CamelContext camelContext, org.apache.activemq.advisory.DestinationSource source)

Method Summary

protected void	addQueue(org.apache.activemq.command.ActiveMQQueue queue)
protected void	addTopic(org.apache.activemq.command.ActiveMQTopic topic)
void	afterPropertiesSet()
org.apache.camel.CamelContext	getCamelContext()
ActiveMQComponent	getComponent()
protected String	getQueueUri(org.apache.activemq.command.ActiveMQQueue queue)
protected String	getTopicUri(org.apache.activemq.command.ActiveMQTopic topic)
protected void	removeQueue(org.apache.activemq.command.ActiveMQQueue queue)
protected void	removeTopic(org.apache.activemq.command.ActiveMQTopic topic)
void	setCamelContext(org.apache.camel.CamelContext camelContext)
void	setComponent(ActiveMQComponent component)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CamelEndpointLoader

public CamelEndpointLoader()

CamelEndpointLoader

public CamelEndpointLoader(org.apache.camel.CamelContext camelContext,
                           org.apache.activemq.advisory.DestinationSource source)

Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        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

getComponent

public ActiveMQComponent getComponent()

setComponent

public void setComponent(ActiveMQComponent component)

addQueue

protected void addQueue(org.apache.activemq.command.ActiveMQQueue queue)
                 throws Exception

Throws:

Exception

getQueueUri

protected String getQueueUri(org.apache.activemq.command.ActiveMQQueue queue)

removeQueue

protected void removeQueue(org.apache.activemq.command.ActiveMQQueue queue)
                    throws Exception

Throws:

Exception

addTopic

protected void addTopic(org.apache.activemq.command.ActiveMQTopic topic)
                 throws Exception

Throws:

Exception

getTopicUri

protected String getTopicUri(org.apache.activemq.command.ActiveMQTopic topic)

removeTopic

protected void removeTopic(org.apache.activemq.command.ActiveMQTopic topic)
                    throws Exception

Throws:

Exception