org.apache.camel.jms
Class CamelDestination
java.lang.Object
org.apache.camel.jms.CamelDestination
- All Implemented Interfaces:
- Destination, org.apache.activemq.CustomDestination, org.apache.camel.CamelContextAware
- Direct Known Subclasses:
- CamelQueue, CamelTopic
public class CamelDestination
- extends Object
- implements org.apache.activemq.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(org.apache.activemq.ActiveMQSession session,
String messageSelector)
- Specified by:
createConsumer
in interface org.apache.activemq.CustomDestination
createConsumer
public MessageConsumer createConsumer(org.apache.activemq.ActiveMQSession session,
String messageSelector,
boolean noLocal)
- Specified by:
createConsumer
in interface org.apache.activemq.CustomDestination
createSubscriber
public TopicSubscriber createSubscriber(org.apache.activemq.ActiveMQSession session,
String messageSelector,
boolean noLocal)
- Specified by:
createSubscriber
in interface org.apache.activemq.CustomDestination
createDurableSubscriber
public TopicSubscriber createDurableSubscriber(org.apache.activemq.ActiveMQSession session,
String name,
String messageSelector,
boolean noLocal)
- Specified by:
createDurableSubscriber
in interface org.apache.activemq.CustomDestination
createReceiver
public QueueReceiver createReceiver(org.apache.activemq.ActiveMQSession session,
String messageSelector)
- Specified by:
createReceiver
in interface org.apache.activemq.CustomDestination
createProducer
public MessageProducer createProducer(org.apache.activemq.ActiveMQSession session)
throws JMSException
- Specified by:
createProducer
in interface org.apache.activemq.CustomDestination
- Throws:
JMSException
createPublisher
public TopicPublisher createPublisher(org.apache.activemq.ActiveMQSession session)
throws JMSException
- Specified by:
createPublisher
in interface org.apache.activemq.CustomDestination
- Throws:
JMSException
createSender
public QueueSender createSender(org.apache.activemq.ActiveMQSession session)
throws JMSException
- Specified by:
createSender
in interface org.apache.activemq.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()
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(org.apache.activemq.ActiveMQSession session)
- Resolves the Camel Endpoint for this destination
- Returns:
resolveCamelContext
protected org.apache.camel.CamelContext resolveCamelContext(org.apache.activemq.ActiveMQSession session)
Copyright © 2007 Apache Software Foundation. All Rights Reserved.