org.apache.activemq.pool
Class PooledTopicPublisher

java.lang.Object
  extended by org.apache.activemq.pool.PooledProducer
      extended by org.apache.activemq.pool.PooledTopicPublisher
All Implemented Interfaces:
MessageProducer, TopicPublisher

public class PooledTopicPublisher
extends PooledProducer
implements TopicPublisher

A TopicPublisher instance that is created and managed by a PooledConnection.


Constructor Summary
PooledTopicPublisher(ActiveMQTopicPublisher messageProducer, Destination destination)
           
 
Method Summary
 Topic getTopic()
           
protected  ActiveMQTopicPublisher getTopicPublisher()
           
 void publish(Message message)
           
 void publish(Message message, int i, int i1, long l)
           
 void publish(Topic topic, Message message)
           
 void publish(Topic topic, 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.MessageProducer
close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive
 

Constructor Detail

PooledTopicPublisher

public PooledTopicPublisher(ActiveMQTopicPublisher messageProducer,
                            Destination destination)
                     throws JMSException
Throws:
JMSException
Method Detail

getTopic

public Topic getTopic()
               throws JMSException
Specified by:
getTopic in interface TopicPublisher
Throws:
JMSException

publish

public void publish(Message message)
             throws JMSException
Specified by:
publish in interface TopicPublisher
Throws:
JMSException

publish

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

publish

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

publish

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

getTopicPublisher

protected ActiveMQTopicPublisher getTopicPublisher()


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