public class PooledTopicPublisher extends PooledProducer implements javax.jms.TopicPublisher
Constructor and Description |
---|
PooledTopicPublisher(ActiveMQTopicPublisher messageProducer,
javax.jms.Destination destination) |
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) |
close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getMessageProducer, getPriority, getTimeToLive, send, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive, toString
public PooledTopicPublisher(ActiveMQTopicPublisher messageProducer, javax.jms.Destination destination) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.Topic getTopic() throws javax.jms.JMSException
getTopic
in interface javax.jms.TopicPublisher
javax.jms.JMSException
public void publish(javax.jms.Message message) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
javax.jms.JMSException
public void publish(javax.jms.Message message, int i, int i1, long l) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
javax.jms.JMSException
public void publish(javax.jms.Topic topic, javax.jms.Message message) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
javax.jms.JMSException
public void publish(javax.jms.Topic topic, javax.jms.Message message, int i, int i1, long l) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
javax.jms.JMSException
protected ActiveMQTopicPublisher getTopicPublisher()
Copyright © 2005–2017. All rights reserved.