public class CamelDestination extends Object implements org.apache.activemq.CustomDestination, org.apache.camel.CamelContextAware
Constructor and Description |
---|
CamelDestination() |
CamelDestination(String uri) |
Modifier and Type | Method and Description |
---|---|
javax.jms.MessageConsumer |
createConsumer(org.apache.activemq.ActiveMQSession session,
String messageSelector) |
javax.jms.MessageConsumer |
createConsumer(org.apache.activemq.ActiveMQSession session,
String messageSelector,
boolean noLocal) |
javax.jms.TopicSubscriber |
createDurableSubscriber(org.apache.activemq.ActiveMQSession session,
String name,
String messageSelector,
boolean noLocal) |
javax.jms.MessageProducer |
createProducer(org.apache.activemq.ActiveMQSession session) |
javax.jms.TopicPublisher |
createPublisher(org.apache.activemq.ActiveMQSession session) |
javax.jms.QueueReceiver |
createReceiver(org.apache.activemq.ActiveMQSession session,
String messageSelector) |
javax.jms.QueueSender |
createSender(org.apache.activemq.ActiveMQSession session) |
javax.jms.TopicSubscriber |
createSubscriber(org.apache.activemq.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(org.apache.activemq.ActiveMQSession session) |
protected org.apache.camel.Endpoint |
resolveEndpoint(org.apache.activemq.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() |
public CamelDestination()
public CamelDestination(String uri)
public javax.jms.MessageConsumer createConsumer(org.apache.activemq.ActiveMQSession session, String messageSelector)
createConsumer
in interface org.apache.activemq.CustomDestination
public javax.jms.MessageConsumer createConsumer(org.apache.activemq.ActiveMQSession session, String messageSelector, boolean noLocal)
createConsumer
in interface org.apache.activemq.CustomDestination
public javax.jms.TopicSubscriber createSubscriber(org.apache.activemq.ActiveMQSession session, String messageSelector, boolean noLocal)
createSubscriber
in interface org.apache.activemq.CustomDestination
public javax.jms.TopicSubscriber createDurableSubscriber(org.apache.activemq.ActiveMQSession session, String name, String messageSelector, boolean noLocal)
createDurableSubscriber
in interface org.apache.activemq.CustomDestination
public javax.jms.QueueReceiver createReceiver(org.apache.activemq.ActiveMQSession session, String messageSelector)
createReceiver
in interface org.apache.activemq.CustomDestination
public javax.jms.MessageProducer createProducer(org.apache.activemq.ActiveMQSession session) throws javax.jms.JMSException
createProducer
in interface org.apache.activemq.CustomDestination
javax.jms.JMSException
public javax.jms.TopicPublisher createPublisher(org.apache.activemq.ActiveMQSession session) throws javax.jms.JMSException
createPublisher
in interface org.apache.activemq.CustomDestination
javax.jms.JMSException
public javax.jms.QueueSender createSender(org.apache.activemq.ActiveMQSession session) throws javax.jms.JMSException
createSender
in interface org.apache.activemq.CustomDestination
javax.jms.JMSException
public String getUri()
public void setUri(String uri)
public org.apache.camel.Endpoint getEndpoint()
public void setEndpoint(org.apache.camel.Endpoint endpoint)
public org.apache.camel.CamelContext getCamelContext()
getCamelContext
in interface org.apache.camel.CamelContextAware
public void setCamelContext(org.apache.camel.CamelContext camelContext)
setCamelContext
in interface org.apache.camel.CamelContextAware
public org.apache.camel.component.jms.JmsBinding getBinding()
public void setBinding(org.apache.camel.component.jms.JmsBinding binding)
protected org.apache.camel.Endpoint resolveEndpoint(org.apache.activemq.ActiveMQSession session)
protected org.apache.camel.CamelContext resolveCamelContext(org.apache.activemq.ActiveMQSession session)
Apache Camel