org.apache.activemq.pool
Class PooledProducer

java.lang.Object
  extended by org.apache.activemq.pool.PooledProducer
All Implemented Interfaces:
javax.jms.MessageProducer
Direct Known Subclasses:
PooledQueueSender, PooledTopicPublisher

public class PooledProducer
extends java.lang.Object
implements javax.jms.MessageProducer

A pooled MessageProducer


Constructor Summary
PooledProducer(ActiveMQMessageProducer messageProducer, javax.jms.Destination destination)
           
 
Method Summary
 void close()
           
 int getDeliveryMode()
           
 javax.jms.Destination getDestination()
           
 boolean getDisableMessageID()
           
 boolean getDisableMessageTimestamp()
           
protected  ActiveMQMessageProducer getMessageProducer()
           
 int getPriority()
           
 long getTimeToLive()
           
 void send(javax.jms.Destination destination, javax.jms.Message message)
           
 void send(javax.jms.Destination destination, javax.jms.Message message, int deliveryMode, int priority, long timeToLive)
           
 void send(javax.jms.Message message)
           
 void send(javax.jms.Message message, int deliveryMode, int priority, long timeToLive)
           
 void setDeliveryMode(int deliveryMode)
           
 void setDisableMessageID(boolean disableMessageID)
           
 void setDisableMessageTimestamp(boolean disableMessageTimestamp)
           
 void setPriority(int priority)
           
 void setTimeToLive(long timeToLive)
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

PooledProducer

public PooledProducer(ActiveMQMessageProducer messageProducer,
                      javax.jms.Destination destination)
               throws javax.jms.JMSException
Throws:
javax.jms.JMSException
Method Detail

close

public void close()
           throws javax.jms.JMSException
Specified by:
close in interface javax.jms.MessageProducer
Throws:
javax.jms.JMSException

send

public void send(javax.jms.Destination destination,
                 javax.jms.Message message)
          throws javax.jms.JMSException
Specified by:
send in interface javax.jms.MessageProducer
Throws:
javax.jms.JMSException

send

public void send(javax.jms.Message message)
          throws javax.jms.JMSException
Specified by:
send in interface javax.jms.MessageProducer
Throws:
javax.jms.JMSException

send

public void send(javax.jms.Message message,
                 int deliveryMode,
                 int priority,
                 long timeToLive)
          throws javax.jms.JMSException
Specified by:
send in interface javax.jms.MessageProducer
Throws:
javax.jms.JMSException

send

public void send(javax.jms.Destination destination,
                 javax.jms.Message message,
                 int deliveryMode,
                 int priority,
                 long timeToLive)
          throws javax.jms.JMSException
Specified by:
send in interface javax.jms.MessageProducer
Throws:
javax.jms.JMSException

getDestination

public javax.jms.Destination getDestination()
Specified by:
getDestination in interface javax.jms.MessageProducer

getDeliveryMode

public int getDeliveryMode()
Specified by:
getDeliveryMode in interface javax.jms.MessageProducer

setDeliveryMode

public void setDeliveryMode(int deliveryMode)
Specified by:
setDeliveryMode in interface javax.jms.MessageProducer

getDisableMessageID

public boolean getDisableMessageID()
Specified by:
getDisableMessageID in interface javax.jms.MessageProducer

setDisableMessageID

public void setDisableMessageID(boolean disableMessageID)
Specified by:
setDisableMessageID in interface javax.jms.MessageProducer

getDisableMessageTimestamp

public boolean getDisableMessageTimestamp()
Specified by:
getDisableMessageTimestamp in interface javax.jms.MessageProducer

setDisableMessageTimestamp

public void setDisableMessageTimestamp(boolean disableMessageTimestamp)
Specified by:
setDisableMessageTimestamp in interface javax.jms.MessageProducer

getPriority

public int getPriority()
Specified by:
getPriority in interface javax.jms.MessageProducer

setPriority

public void setPriority(int priority)
Specified by:
setPriority in interface javax.jms.MessageProducer

getTimeToLive

public long getTimeToLive()
Specified by:
getTimeToLive in interface javax.jms.MessageProducer

setTimeToLive

public void setTimeToLive(long timeToLive)
Specified by:
setTimeToLive in interface javax.jms.MessageProducer

getMessageProducer

protected ActiveMQMessageProducer getMessageProducer()

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object


Copyright © 2005-2012. All Rights Reserved.