public class CamelMessageProducer
extends org.apache.activemq.ActiveMQMessageProducerSupport
MessageProducer
which sends message exchanges to a
Camel Endpoint
Modifier and Type | Field and Description |
---|---|
protected org.apache.camel.Producer |
producer |
Constructor and Description |
---|
CamelMessageProducer(CamelDestination destination,
org.apache.camel.Endpoint endpoint,
org.apache.activemq.ActiveMQSession session) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkClosed() |
void |
close() |
CamelDestination |
getDestination() |
org.apache.camel.Endpoint |
getEndpoint() |
void |
send(javax.jms.Destination destination,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive) |
getDeliveryMode, getDisableMessageID, getDisableMessageTimestamp, getPriority, getSendTimeout, getTimeToLive, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setSendTimeout, setTimeToLive
public CamelMessageProducer(CamelDestination destination, org.apache.camel.Endpoint endpoint, org.apache.activemq.ActiveMQSession session) throws javax.jms.JMSException
javax.jms.JMSException
public CamelDestination getDestination() throws javax.jms.JMSException
javax.jms.JMSException
public org.apache.camel.Endpoint getEndpoint()
public void close() throws javax.jms.JMSException
javax.jms.JMSException
public void send(javax.jms.Destination destination, javax.jms.Message message, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
javax.jms.JMSException
protected void checkClosed() throws javax.jms.IllegalStateException
checkClosed
in class org.apache.activemq.ActiveMQMessageProducerSupport
javax.jms.IllegalStateException
Apache Camel