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 java.lang.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)
           
 
Method Summary
protected  void addQueue(ActiveMQQueue queue)
           
protected  void addTopic(ActiveMQTopic topic)
           
 void afterPropertiesSet()
           
 void destroy()
           
 org.apache.camel.CamelContext getCamelContext()
           
 ActiveMQComponent getComponent()
           
 EnhancedConnection getConnection()
           
 javax.jms.ConnectionFactory getConnectionFactory()
           
protected  java.lang.String getQueueUri(ActiveMQQueue queue)
           
protected  java.lang.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)
           
 void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)
           
 
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)
Method Detail

afterPropertiesSet

@PostConstruct
public void afterPropertiesSet()
                        throws java.lang.Exception
Throws:
java.lang.Exception

destroy

@PreDestroy
public void destroy()
             throws java.lang.Exception
Throws:
java.lang.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 javax.jms.ConnectionFactory getConnectionFactory()

setConnectionFactory

public void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)

getComponent

public ActiveMQComponent getComponent()

setComponent

public void setComponent(ActiveMQComponent component)

addQueue

protected void addQueue(ActiveMQQueue queue)
                 throws java.lang.Exception
Throws:
java.lang.Exception

getQueueUri

protected java.lang.String getQueueUri(ActiveMQQueue queue)

removeQueue

protected void removeQueue(ActiveMQQueue queue)
                    throws java.lang.Exception
Throws:
java.lang.Exception

addTopic

protected void addTopic(ActiveMQTopic topic)
                 throws java.lang.Exception
Throws:
java.lang.Exception

getTopicUri

protected java.lang.String getTopicUri(ActiveMQTopic topic)

removeTopic

protected void removeTopic(ActiveMQTopic topic)
                    throws java.lang.Exception
Throws:
java.lang.Exception


Copyright © 2005-2011 FuseSource, Corp.. All Rights Reserved.