Package org.apache.activemq.jms.pool

Class PooledTopicPublisher

java.lang.Object

org.apache.activemq.jms.pool.PooledProducer

org.apache.activemq.jms.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

Constructors

Constructor	Description
PooledTopicPublisher(TopicPublisher messageProducer, Destination destination)

Method Summary

Modifier and Type	Method	Description
Topic	getTopic()
protected TopicPublisher	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.jms.pool.PooledProducer

close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getMessageProducer, getPriority, getTimeToLive, isAnonymous, 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(TopicPublisher 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 TopicPublisher getTopicPublisher()