public class CamelQueueSender extends CamelMessageProducer implements javax.jms.QueueSender
QueueSender
which sends message exchanges to a Camel
Endpoint
producer
Constructor and Description |
---|
CamelQueueSender(CamelQueue destination,
org.apache.camel.Endpoint endpoint,
org.apache.activemq.ActiveMQSession session) |
Modifier and Type | Method and Description |
---|---|
javax.jms.Queue |
getQueue()
Gets the queue associated with this
QueueSender . |
void |
send(javax.jms.Queue queue,
javax.jms.Message message)
Sends a message to a queue for an unidentified message producer.
|
void |
send(javax.jms.Queue queue,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
Sends a message to a queue for an unidentified message producer,
specifying delivery mode, priority and time to live.
|
checkClosed, close, getDestination, getEndpoint, send
getDeliveryMode, getDisableMessageID, getDisableMessageTimestamp, getPriority, getSendTimeout, getTimeToLive, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setSendTimeout, setTimeToLive
public CamelQueueSender(CamelQueue destination, org.apache.camel.Endpoint endpoint, org.apache.activemq.ActiveMQSession session) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.Queue getQueue() throws javax.jms.JMSException
QueueSender
.getQueue
in interface javax.jms.QueueSender
javax.jms.JMSException
- if the JMS provider fails to get the queue for this
QueueSender
due to some internal error.public void send(javax.jms.Queue queue, javax.jms.Message message) throws javax.jms.JMSException
QueueSender
's default delivery mode, priority, and time
to live. Typically, a message producer is assigned a queue at
creation time; however, the JMS API also supports unidentified message
producers, which require that the queue be supplied every time a message
is sent.send
in interface javax.jms.QueueSender
queue
- the queue to send this message tomessage
- the message to sendjavax.jms.JMSException
- if the JMS provider fails to send the message due to
some internal error.MessageProducer.getDeliveryMode()
,
MessageProducer.getTimeToLive()
,
MessageProducer.getPriority()
public void send(javax.jms.Queue queue, javax.jms.Message message, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
send
in interface javax.jms.QueueSender
queue
- the queue to send this message tomessage
- the message to senddeliveryMode
- the delivery mode to usepriority
- the priority for this messagetimeToLive
- the message's lifetime (in milliseconds)javax.jms.JMSException
- if the JMS provider fails to send the message due to
some internal error.Apache Camel