org.apache.activemq.pool
Class PooledQueueSender

java.lang.Object
  extended by org.apache.activemq.pool.PooledProducer
      extended by org.apache.activemq.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
PooledQueueSender(ActiveMQQueueSender messageProducer, Destination destination)
           
 
Method Summary
 Queue getQueue()
           
protected  ActiveMQQueueSender 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.pool.PooledProducer
close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getMessageProducer, 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

PooledQueueSender

public PooledQueueSender(ActiveMQQueueSender 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 interface QueueSender
Throws:
JMSException

send

public void send(Queue queue,
                 Message message)
          throws JMSException
Specified by:
send in interface QueueSender
Throws:
JMSException

getQueue

public Queue getQueue()
               throws JMSException
Specified by:
getQueue in interface QueueSender
Throws:
JMSException

getQueueSender

protected ActiveMQQueueSender getQueueSender()


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.