Package 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:
MessageProducer
,QueueSender
public class PooledQueueSender extends PooledProducer implements QueueSender
QueueSender
instance that is created and managed by the PooledConnection.
-
-
Constructor Summary
Constructors Constructor Description PooledQueueSender(QueueSender messageProducer, Destination destination)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Queue
getQueue()
protected QueueSender
getQueueSender()
void
send(Queue queue, Message message)
void
send(Queue queue, 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.MessageProducer
close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive
-
Methods inherited from interface javax.jms.QueueSender
send, send
-
-
-
-
Constructor Detail
-
PooledQueueSender
public PooledQueueSender(QueueSender messageProducer, Destination destination) throws JMSException
- Throws:
JMSException
-
-
Method Detail
-
send
public void send(Queue queue, Message message, int i, int i1, long l) throws JMSException
- Specified by:
send
in interfaceQueueSender
- Throws:
JMSException
-
send
public void send(Queue queue, Message message) throws JMSException
- Specified by:
send
in interfaceQueueSender
- Throws:
JMSException
-
getQueue
public Queue getQueue() throws JMSException
- Specified by:
getQueue
in interfaceQueueSender
- Throws:
JMSException
-
getQueueSender
protected QueueSender getQueueSender()
-
-