org.apache.activemq.jms.pool

Class PooledQueueSender

java.lang.Object

org.apache.activemq.jms.pool.PooledProducer

org.apache.activemq.jms.pool.PooledQueueSender

All Implemented Interfaces:

javax.jms.MessageProducer, javax.jms.QueueSender

public class PooledQueueSender
extends PooledProducer
implements javax.jms.QueueSender

QueueSender instance that is created and managed by the PooledConnection.

Constructor Summary

Constructors

Constructor and Description
PooledQueueSender(javax.jms.QueueSender messageProducer, javax.jms.Destination destination)

Method Summary

Methods

Modifier and Type	Method and Description
javax.jms.Queue	getQueue()
protected javax.jms.QueueSender	getQueueSender()
void	send(javax.jms.Queue queue, javax.jms.Message message)
void	send(javax.jms.Queue queue, javax.jms.Message message, int i, int i1, long l)

Methods inherited from class org.apache.activemq.jms.pool.PooledProducer

close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getMessageProducer, getPriority, getTimeToLive, isAnonymous, 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

PooledQueueSender

public PooledQueueSender(javax.jms.QueueSender messageProducer,
                 javax.jms.Destination destination)
                  throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Method Detail

send

public void send(javax.jms.Queue queue,
        javax.jms.Message message,
        int i,
        int i1,
        long l)
          throws javax.jms.JMSException

Specified by:

send in interface javax.jms.QueueSender

Throws:

javax.jms.JMSException

send

public void send(javax.jms.Queue queue,
        javax.jms.Message message)
          throws javax.jms.JMSException

Specified by:

send in interface javax.jms.QueueSender

Throws:

javax.jms.JMSException

getQueue

public javax.jms.Queue getQueue()
                         throws javax.jms.JMSException

Specified by:

getQueue in interface javax.jms.QueueSender

Throws:

javax.jms.JMSException

getQueueSender

protected javax.jms.QueueSender getQueueSender()