org.apache.activemq.camel
Class CamelDestination

java.lang.Object
  extended by org.apache.activemq.camel.CamelDestination
All Implemented Interfaces:
Destination, CustomDestination, org.apache.camel.CamelContextAware
Direct Known Subclasses:
CamelQueue, CamelTopic

public class CamelDestination
extends Object
implements CustomDestination, org.apache.camel.CamelContextAware


Constructor Summary
CamelDestination()
           
CamelDestination(String uri)
           
 
Method Summary
 MessageConsumer createConsumer(ActiveMQSession session, String messageSelector)
           
 MessageConsumer createConsumer(ActiveMQSession session, String messageSelector, boolean noLocal)
           
 TopicSubscriber createDurableSubscriber(ActiveMQSession session, String name, String messageSelector, boolean noLocal)
           
 MessageProducer createProducer(ActiveMQSession session)
           
 TopicPublisher createPublisher(ActiveMQSession session)
           
 QueueReceiver createReceiver(ActiveMQSession session, String messageSelector)
           
 QueueSender createSender(ActiveMQSession session)
           
 TopicSubscriber createSubscriber(ActiveMQSession session, String messageSelector, boolean noLocal)
           
 org.apache.camel.component.jms.JmsBinding getBinding()
           
 org.apache.camel.CamelContext getCamelContext()
           
 org.apache.camel.Endpoint getEndpoint()
           
 String getUri()
           
protected  org.apache.camel.CamelContext resolveCamelContext(ActiveMQSession session)
           
protected  org.apache.camel.Endpoint resolveEndpoint(ActiveMQSession session)
          Resolves the Camel Endpoint for this destination
 void setBinding(org.apache.camel.component.jms.JmsBinding binding)
           
 void setCamelContext(org.apache.camel.CamelContext camelContext)
           
 void setEndpoint(org.apache.camel.Endpoint endpoint)
           
 void setUri(String uri)
           
 String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

CamelDestination

public CamelDestination()

CamelDestination

public CamelDestination(String uri)
Method Detail

toString

public String toString()
Overrides:
toString in class Object

createConsumer

public MessageConsumer createConsumer(ActiveMQSession session,
                                      String messageSelector)
Specified by:
createConsumer in interface CustomDestination

createConsumer

public MessageConsumer createConsumer(ActiveMQSession session,
                                      String messageSelector,
                                      boolean noLocal)
Specified by:
createConsumer in interface CustomDestination

createSubscriber

public TopicSubscriber createSubscriber(ActiveMQSession session,
                                        String messageSelector,
                                        boolean noLocal)
Specified by:
createSubscriber in interface CustomDestination

createDurableSubscriber

public TopicSubscriber createDurableSubscriber(ActiveMQSession session,
                                               String name,
                                               String messageSelector,
                                               boolean noLocal)
Specified by:
createDurableSubscriber in interface CustomDestination

createReceiver

public QueueReceiver createReceiver(ActiveMQSession session,
                                    String messageSelector)
Specified by:
createReceiver in interface CustomDestination

createProducer

public MessageProducer createProducer(ActiveMQSession session)
                               throws JMSException
Specified by:
createProducer in interface CustomDestination
Throws:
JMSException

createPublisher

public TopicPublisher createPublisher(ActiveMQSession session)
                               throws JMSException
Specified by:
createPublisher in interface CustomDestination
Throws:
JMSException

createSender

public QueueSender createSender(ActiveMQSession session)
                         throws JMSException
Specified by:
createSender in interface CustomDestination
Throws:
JMSException

getUri

public String getUri()

setUri

public void setUri(String uri)

getEndpoint

public org.apache.camel.Endpoint getEndpoint()

setEndpoint

public void setEndpoint(org.apache.camel.Endpoint endpoint)

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

getBinding

public org.apache.camel.component.jms.JmsBinding getBinding()

setBinding

public void setBinding(org.apache.camel.component.jms.JmsBinding binding)

resolveEndpoint

protected org.apache.camel.Endpoint resolveEndpoint(ActiveMQSession session)
Resolves the Camel Endpoint for this destination

Returns:

resolveCamelContext

protected org.apache.camel.CamelContext resolveCamelContext(ActiveMQSession session)


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.