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.

Field Summary

Fields inherited from class com.caucho.jms.connection.MessageProducerImpl

_queue, _session, DEFAULT_TIME_TO_LIVE

Constructor Summary

Constructors

Constructor and Description
QueueSenderImpl(JmsSession session, AbstractQueue queue)

Method Summary

Modifier and Type	Method and Description
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.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

QueueSenderImpl

public QueueSenderImpl(JmsSession session,
                       AbstractQueue queue)

Method Detail

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 to

message - 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 to

message - the message to send

deliveryMode - the delivery mode

priority - the priority

timeToLive - how long the message should live

Throws:

JMSException