Class WmQueueSenderImpl
- java.lang.Object
-
- com.webmethods.locks.Node
-
- com.webmethods.jms.impl.WmMessageProducerImpl
-
- com.webmethods.jms.impl.WmQueueSenderImpl
-
- All Implemented Interfaces:
WmMessageProducer
,WmQueueSender
,javax.jms.MessageProducer
,javax.jms.QueueSender
- Direct Known Subclasses:
WmClusterMultiSendQueueSenderImpl
,WmClusterQueueSenderImpl
public class WmQueueSenderImpl extends WmMessageProducerImpl implements WmQueueSender
-
-
Field Summary
-
Fields inherited from class com.webmethods.jms.impl.WmMessageProducerImpl
_destination, _logApi, _session
-
Fields inherited from class com.webmethods.locks.Node
_lockManager
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
WmQueueSenderImpl(WmSessionImpl session, WmQueueImpl queue)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description javax.jms.Queue
getQueue()
Gets the queue associated with thisQueueSender
.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[] messages)
Sends multiple messages to a queue for an unidentified message producer.void
send(javax.jms.Queue queue, javax.jms.Message[] messages, int deliveryMode, int priority, long timeToLive)
Sends multiple messages to a queue for an unidentified message producer, specifying delivery mode, priority and time to live.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 com.webmethods.jms.impl.WmMessageProducerImpl
checkState, close, deliveryModeToString, getCompressionLevel, getCompressionThreshold, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getOutputStream, getOutputStream, getPriority, getTimeToLive, nextMessageIdentifier, reconnect, send, send, send, send, send, send, send, send, setCompressionLevel, setCompressionThreshold, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive, toString
-
Methods inherited from class com.webmethods.locks.Node
getLockManager, getParent
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface javax.jms.MessageProducer
close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive
-
Methods inherited from interface com.webmethods.jms.WmMessageProducer
getCompressionLevel, getCompressionThreshold, getOutputStream, getOutputStream, send, send, send, send, setCompressionLevel, setCompressionThreshold
-
-
-
-
Constructor Detail
-
WmQueueSenderImpl
protected WmQueueSenderImpl(WmSessionImpl session, WmQueueImpl queue)
-
-
Method Detail
-
getQueue
public javax.jms.Queue getQueue() throws javax.jms.JMSException
Gets the queue associated with thisQueueSender
.- Specified by:
getQueue
in interfacejavax.jms.QueueSender
- Returns:
- this sender's queue
- Throws:
javax.jms.JMSException
- if the JMS provider fails to get the queue for thisQueueSender
due to some internal error.
-
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 theQueueSender
'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
- Parameters:
queue
- the queue to send this message tomessage
- the message to send- Throws:
javax.jms.JMSException
- if the JMS provider fails to send the message due to some internal error.javax.jms.MessageFormatException
- if an invalid message is specified.javax.jms.InvalidDestinationException
- if a client uses this method with an invalid queue.- See Also:
MessageProducer.getDeliveryMode()
,MessageProducer.getTimeToLive()
,MessageProducer.getPriority()
-
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
- 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:
javax.jms.JMSException
- if the JMS provider fails to send the message due to some internal error.javax.jms.MessageFormatException
- if an invalid message is specified.javax.jms.InvalidDestinationException
- if a client uses this method with an invalid queue.
-
send
public void send(javax.jms.Queue queue, javax.jms.Message[] messages) throws javax.jms.JMSException
Sends multiple messages to a queue for an unidentified message producer. Uses theQueueSender
'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 interfaceWmQueueSender
- Parameters:
queue
- the queue to send the messages tomessages
- the messages to send- Throws:
javax.jms.JMSException
- if the JMS provider fails to send the message due to some internal error.javax.jms.MessageFormatException
- if an invalid message is specified.javax.jms.InvalidDestinationException
- if a client uses this method with an invalid queue.- See Also:
MessageProducer.getDeliveryMode()
,MessageProducer.getTimeToLive()
,MessageProducer.getPriority()
-
send
public void send(javax.jms.Queue queue, javax.jms.Message[] messages, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
Sends multiple messages 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 interfaceWmQueueSender
- Parameters:
queue
- the queue to send the messages tomessages
- the messages to senddeliveryMode
- the delivery mode to usepriority
- the priority for this messagetimeToLive
- the message's lifetime (in milliseconds)- Throws:
javax.jms.JMSException
- if the JMS provider fails to send the message due to some internal error.javax.jms.MessageFormatException
- if an invalid message is specified.javax.jms.InvalidDestinationException
- if a client uses this method with an invalid queue.
-
-