|
|||||||||
Home >> All >> org >> [ activemq overview ] | PREV CLASS NEXT CLASS | ||||||||
SUMMARY: ![]() ![]() ![]() |
DETAIL: FIELD | CONSTR | METHOD |
org.activemq
Class ActiveMQQueueSender

java.lang.Objectorg.activemq.ActiveMQMessageProducer
org.activemq.ActiveMQQueueSender
- All Implemented Interfaces:
- Closeable, javax.jms.MessageProducer, javax.jms.QueueSender, org.activemq.management.StatsCapable
- public class ActiveMQQueueSender
- extends ActiveMQMessageProducer
- implements javax.jms.QueueSender
- extends ActiveMQMessageProducer
A client uses a QueueSender
object to send messages to a
queue.
Normally, the Queue
is specified when a QueueSender
is created. In this case, an attempt to use the send
methods for an unidentified QueueSender
will throw a
java.lang.UnsupportedOperationException
.
If the QueueSender
is created with an unidentified
Queue
, an attempt to use the send
methods that
assume that the Queue
has been identified will throw a
java.lang.UnsupportedOperationException
.
During the execution of its send
method, a message must not
be changed by other threads within the client. If the message is modified,
the result of the send
is undefined.
After sending a message, a client may retain and modify it without affecting the message that has been sent. The same message object may be sent multiple times.
The following message headers are set as part of sending a message: JMSDestination
,
JMSDeliveryMode
,JMSExpiration
,JMSPriority
,
JMSMessageID
and JMSTimeStamp
. When the
message is sent, the values of these headers are ignored. After the
completion of the send
, the headers hold the values
specified by the method sending the message. It is possible for the send
method not to set JMSMessageID
and JMSTimeStamp
if the setting of these headers is explicitly disabled by the MessageProducer.setDisableMessageID
or MessageProducer.setDisableMessageTimestamp
method.
Creating a MessageProducer
provides the same features as
creating a QueueSender
. A MessageProducer
object is recommended when creating new code. The QueueSender
is provided to support existing code.
Field Summary |
Fields inherited from class org.activemq.ActiveMQMessageProducer |
closed, defaultDestination, session |
Constructor Summary | |
protected |
ActiveMQQueueSender(ActiveMQSession session,
org.activemq.message.ActiveMQDestination destination)
|
Method Summary | |
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. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface javax.jms.QueueSender |
send, send |
Methods inherited from interface javax.jms.MessageProducer |
close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive |
Constructor Detail |
ActiveMQQueueSender
protected ActiveMQQueueSender(ActiveMQSession session, org.activemq.message.ActiveMQDestination destination) throws javax.jms.JMSException
Method Detail |
getQueue
public javax.jms.Queue getQueue() throws javax.jms.JMSException
- Gets the queue associated with this
QueueSender
.- Specified by:
getQueue
in interfacejavax.jms.QueueSender
send
public void send(javax.jms.Queue queue, javax.jms.Message message) throws javax.jms.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 interfacejavax.jms.QueueSender
send
public void send(javax.jms.Queue queue, javax.jms.Message message, int deliveryMode, int priority, long timeToLive) throws javax.jms.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 interfacejavax.jms.QueueSender
|
|||||||||
Home >> All >> org >> [ activemq overview ] | PREV CLASS NEXT CLASS | ||||||||
SUMMARY: ![]() ![]() ![]() |
DETAIL: FIELD | CONSTR | METHOD |