Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.activemq.pool
Class PooledTopicPublisher  view PooledTopicPublisher download PooledTopicPublisher.java

java.lang.Object
  extended byorg.activemq.pool.PooledProducer
      extended byorg.activemq.pool.PooledTopicPublisher
All Implemented Interfaces:
javax.jms.MessageProducer, javax.jms.TopicPublisher

public class PooledTopicPublisher
extends PooledProducer
implements javax.jms.TopicPublisher

Version:
$Revision: 1.1 $

Field Summary
 
Fields inherited from class org.activemq.pool.PooledProducer
 
Constructor Summary
PooledTopicPublisher(org.activemq.ActiveMQTopicPublisher messageProducer, javax.jms.Destination destination)
           
 
Method Summary
 javax.jms.Topic getTopic()
           
protected  org.activemq.ActiveMQTopicPublisher getTopicPublisher()
           
 void publish(javax.jms.Message message)
           
 void publish(javax.jms.Message message, int i, int i1, long l)
           
 void publish(javax.jms.Topic topic, javax.jms.Message message)
           
 void publish(javax.jms.Topic topic, javax.jms.Message message, int i, int i1, long l)
           
 
Methods inherited from class org.activemq.pool.PooledProducer
close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getMessageProducer, getPriority, getTimeToLive, send, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface javax.jms.MessageProducer
close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive
 

Constructor Detail

PooledTopicPublisher

public PooledTopicPublisher(org.activemq.ActiveMQTopicPublisher messageProducer,
                            javax.jms.Destination destination)
                     throws javax.jms.JMSException
Method Detail

getTopic

public javax.jms.Topic getTopic()
                         throws javax.jms.JMSException
Specified by:
getTopic in interface javax.jms.TopicPublisher

publish

public void publish(javax.jms.Message message)
             throws javax.jms.JMSException
Specified by:
publish in interface javax.jms.TopicPublisher

publish

public void publish(javax.jms.Message message,
                    int i,
                    int i1,
                    long l)
             throws javax.jms.JMSException
Specified by:
publish in interface javax.jms.TopicPublisher

publish

public void publish(javax.jms.Topic topic,
                    javax.jms.Message message)
             throws javax.jms.JMSException
Specified by:
publish in interface javax.jms.TopicPublisher

publish

public void publish(javax.jms.Topic topic,
                    javax.jms.Message message,
                    int i,
                    int i1,
                    long l)
             throws javax.jms.JMSException
Specified by:
publish in interface javax.jms.TopicPublisher

getTopicPublisher

protected org.activemq.ActiveMQTopicPublisher getTopicPublisher()