org.apache.activemq.camel
Class CamelQueueSender
java.lang.Object
org.apache.activemq.ActiveMQMessageProducerSupport
org.apache.activemq.camel.CamelMessageProducer
org.apache.activemq.camel.CamelQueueSender
- All Implemented Interfaces:
- MessageProducer, QueueSender, Closeable
public class CamelQueueSender
- extends CamelMessageProducer
- implements QueueSender
A JMS QueueSender
which sends message exchanges to a Camel
Endpoint
- Version:
- $Revision: $
Method Summary |
Queue |
getQueue()
Gets the queue associated with this QueueSender . |
void |
send(Queue queue,
Message message)
Sends a message to a queue for an unidentified message producer. |
void |
send(Queue queue,
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. |
Methods inherited from class org.apache.activemq.ActiveMQMessageProducerSupport |
getDeliveryMode, getDisableMessageID, getDisableMessageTimestamp, getPriority, getSendTimeout, getTimeToLive, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setSendTimeout, setTimeToLive |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface javax.jms.MessageProducer |
close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive |
CamelQueueSender
public CamelQueueSender(CamelQueue destination,
org.apache.camel.Endpoint endpoint,
ActiveMQSession session)
throws JMSException
- Throws:
JMSException
getQueue
public Queue getQueue()
throws JMSException
- Gets the queue associated with this
QueueSender
.
- Specified by:
getQueue
in interface QueueSender
- Returns:
- this sender's queue
- Throws:
JMSException
- if the JMS provider fails to get the queue for this
QueueSender
due to some internal error.
send
public void send(Queue queue,
Message message)
throws JMSException
- Sends a message to a queue for an unidentified message producer. Uses the
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.
- Specified by:
send
in interface QueueSender
- Parameters:
queue
- the queue to send this message tomessage
- the message to send
- Throws:
JMSException
- if the JMS provider fails to send the message due to
some internal error.- See Also:
MessageProducer.getDeliveryMode()
,
MessageProducer.getTimeToLive()
,
MessageProducer.getPriority()
send
public void send(Queue queue,
Message message,
int deliveryMode,
int priority,
long timeToLive)
throws JMSException
- Sends a message to a queue for an unidentified message producer,
specifying 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.
- Specified by:
send
in interface QueueSender
- Parameters:
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)
- Throws:
JMSException
- if the JMS provider fails to send the message due to
some internal error.
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.