com.caucho.jms.connection
Class QueueSenderImpl
java.lang.Object
com.caucho.jms.connection.MessageProducerImpl
com.caucho.jms.connection.QueueSenderImpl
- All Implemented Interfaces:
- MessageProducer, QueueSender
public class QueueSenderImpl
- extends MessageProducerImpl
- implements QueueSender
A basic queue.
Method Summary |
Queue |
getQueue()
Returns the queue |
void |
send(Queue queue,
Message message)
Sends a message to the queue |
void |
send(Queue queue,
Message message,
int deliveryMode,
int priority,
long timeToLive)
Sends a message to the queue |
Methods inherited from class com.caucho.jms.connection.MessageProducerImpl |
calculateExpiration, close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive, toString |
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 |
QueueSenderImpl
public QueueSenderImpl(JmsSession session,
AbstractQueue queue)
getQueue
public Queue getQueue()
throws JMSException
- Returns the queue
- Specified by:
getQueue
in interface QueueSender
- Throws:
JMSException
send
public void send(Queue queue,
Message message)
throws JMSException
- Sends a message to the queue
- Specified by:
send
in interface QueueSender
- Parameters:
queue
- the queue the message should be send tomessage
- the message to send
- Throws:
JMSException
send
public void send(Queue queue,
Message message,
int deliveryMode,
int priority,
long timeToLive)
throws JMSException
- Sends a message to the queue
- Specified by:
send
in interface QueueSender
- Parameters:
queue
- the queue the message should be send tomessage
- the message to senddeliveryMode
- the delivery modepriority
- the prioritytimeToLive
- how long the message should live
- Throws:
JMSException