org.apache.activemq.camel.component
Class CamelEndpointLoader

java.lang.Object
  extended by 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, DestinationSource source)
           
 
Method Summary
protected  void addQueue(ActiveMQQueue queue)
           
protected  void addTopic(ActiveMQTopic topic)
           
 void afterPropertiesSet()
           
 org.apache.camel.CamelContext getCamelContext()
           
 ActiveMQComponent getComponent()
           
protected  String getQueueUri(ActiveMQQueue queue)
           
protected  String getTopicUri(ActiveMQTopic topic)
           
protected  void removeQueue(ActiveMQQueue queue)
           
protected  void removeTopic(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,
                           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(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–2013 The Apache Software Foundation. All rights reserved.