org.apache.activemq.pool

Class PooledTopicPublisher

java.lang.Object

org.apache.activemq.pool.PooledProducer

org.apache.activemq.pool.PooledTopicPublisher

All Implemented Interfaces:

javax.jms.MessageProducer, javax.jms.TopicPublisher

public class PooledTopicPublisher
extends PooledProducer
implements javax.jms.TopicPublisher

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

Constructor Summary

Constructors

Constructor and Description
PooledTopicPublisher(ActiveMQTopicPublisher messageProducer, javax.jms.Destination destination)

Method Summary

Methods

Modifier and Type	Method and Description
javax.jms.Topic	getTopic()
protected 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.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,
                    javax.jms.Destination destination)
                     throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Method Detail

getTopic

public javax.jms.Topic getTopic()
                         throws javax.jms.JMSException

Specified by:

getTopic in interface javax.jms.TopicPublisher

Throws:

javax.jms.JMSException

publish

public void publish(javax.jms.Message message)
             throws javax.jms.JMSException

Specified by:

publish in interface javax.jms.TopicPublisher

Throws:

javax.jms.JMSException

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

Throws:

javax.jms.JMSException

publish

public void publish(javax.jms.Topic topic,
           javax.jms.Message message)
             throws javax.jms.JMSException

Specified by:

publish in interface javax.jms.TopicPublisher

Throws:

javax.jms.JMSException

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

Throws:

javax.jms.JMSException

getTopicPublisher

protected ActiveMQTopicPublisher getTopicPublisher()