org.apache.camel.jms
Class CamelQueueSender
java.lang.Object
org.apache.activemq.ActiveMQMessageProducerSupport
org.apache.camel.jms.CamelMessageProducer
org.apache.camel.jms.CamelQueueSender
- All Implemented Interfaces:
- MessageProducer, QueueSender, org.apache.activemq.Closeable
public class CamelQueueSender
- extends CamelMessageProducer
- implements QueueSender
A JMS QueueSender
which sends message exchanges to a
Camel Endpoint
- Version:
- $Revision: $
Fields inherited from class org.apache.activemq.ActiveMQMessageProducerSupport |
defaultDeliveryMode, defaultPriority, defaultTimeToLive, disableMessageID, disableMessageTimestamp, session |
Constructor Summary |
CamelQueueSender(CamelQueue destination,
org.apache.camel.Endpoint endpoint,
org.apache.activemq.ActiveMQSession session)
|
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, getTimeToLive, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, 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,
org.apache.activemq.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 © 2007 Apache Software Foundation. All Rights Reserved.