org.apache.activemq.camel
Class CamelDestination
java.lang.Object
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
- Version:
- $Revision: $
CamelDestination
public CamelDestination()
CamelDestination
public CamelDestination(String uri)
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-2011 Apache Software Foundation. All Rights Reserved.