public class CamelMessageConsumer extends Object implements javax.jms.MessageConsumer
MessageConsumer
which consumes message exchanges from
a Camel Endpoint
Constructor and Description |
---|
CamelMessageConsumer(CamelDestination destination,
org.apache.camel.Endpoint endpoint,
org.apache.activemq.ActiveMQSession session,
String messageSelector,
boolean noLocal) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkClosed() |
void |
close() |
protected org.apache.camel.Consumer |
createConsumer() |
protected javax.jms.Message |
createMessage(org.apache.camel.Exchange exchange) |
CamelDestination |
getDestination() |
org.apache.camel.Endpoint |
getEndpoint() |
javax.jms.MessageListener |
getMessageListener() |
String |
getMessageSelector() |
protected org.apache.camel.PollingConsumer |
getPollingConsumer() |
org.apache.activemq.ActiveMQSession |
getSession() |
boolean |
isNoLocal() |
javax.jms.Message |
receive() |
javax.jms.Message |
receive(long timeoutMillis) |
javax.jms.Message |
receiveNoWait() |
void |
setMessageListener(javax.jms.MessageListener messageListener) |
public CamelMessageConsumer(CamelDestination destination, org.apache.camel.Endpoint endpoint, org.apache.activemq.ActiveMQSession session, String messageSelector, boolean noLocal)
public void close() throws javax.jms.JMSException
close
in interface javax.jms.MessageConsumer
javax.jms.JMSException
public javax.jms.MessageListener getMessageListener() throws javax.jms.JMSException
getMessageListener
in interface javax.jms.MessageConsumer
javax.jms.JMSException
public void setMessageListener(javax.jms.MessageListener messageListener) throws javax.jms.JMSException
setMessageListener
in interface javax.jms.MessageConsumer
javax.jms.JMSException
public javax.jms.Message receive() throws javax.jms.JMSException
receive
in interface javax.jms.MessageConsumer
javax.jms.JMSException
public javax.jms.Message receive(long timeoutMillis) throws javax.jms.JMSException
receive
in interface javax.jms.MessageConsumer
javax.jms.JMSException
public javax.jms.Message receiveNoWait() throws javax.jms.JMSException
receiveNoWait
in interface javax.jms.MessageConsumer
javax.jms.JMSException
public CamelDestination getDestination()
public org.apache.camel.Endpoint getEndpoint()
public String getMessageSelector()
getMessageSelector
in interface javax.jms.MessageConsumer
public boolean isNoLocal()
public org.apache.activemq.ActiveMQSession getSession()
protected org.apache.camel.PollingConsumer getPollingConsumer() throws javax.jms.JMSException
javax.jms.JMSException
protected javax.jms.Message createMessage(org.apache.camel.Exchange exchange) throws javax.jms.JMSException
javax.jms.JMSException
protected org.apache.camel.Consumer createConsumer() throws javax.jms.JMSException
javax.jms.JMSException
protected void checkClosed() throws javax.jms.IllegalStateException
javax.jms.IllegalStateException
Apache Camel