public class JmsTopicPublisher extends JmsMessageProducer implements AutoCloseable, javax.jms.TopicPublisher
closed, connection, deliveryMode, disableMessageId, disableTimestamp, failureCause, flexibleDestination, messageSequence, priority, producerInfo, session, timeToLive
Modifier | Constructor and Description |
---|---|
protected |
JmsTopicPublisher(JmsProducerId id,
JmsSession session,
JmsDestination destination) |
Modifier and Type | Method and Description |
---|---|
javax.jms.Topic |
getTopic() |
void |
publish(javax.jms.Message message) |
void |
publish(javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive) |
void |
publish(javax.jms.Topic topic,
javax.jms.Message message) |
void |
publish(javax.jms.Topic topic,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive) |
checkClosed, close, doClose, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getNextMessageSequence, getPriority, getProducerId, getTimeToLive, onConnectionInterrupted, onConnectionRecovered, onConnectionRecovery, onConnectionRestored, send, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive, shutdown, shutdown
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
protected JmsTopicPublisher(JmsProducerId id, JmsSession session, JmsDestination destination) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.Topic getTopic() throws javax.jms.IllegalStateException
getTopic
in interface javax.jms.TopicPublisher
javax.jms.IllegalStateException
TopicPublisher.getTopic()
public void publish(javax.jms.Message message) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
javax.jms.JMSException
TopicPublisher.publish(javax.jms.Message)
public void publish(javax.jms.Topic topic, javax.jms.Message message) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
javax.jms.JMSException
TopicPublisher.publish(javax.jms.Topic, javax.jms.Message)
public void publish(javax.jms.Message message, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
javax.jms.JMSException
TopicPublisher.publish(javax.jms.Message, int, int, long)
public void publish(javax.jms.Topic topic, javax.jms.Message message, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
javax.jms.JMSException
TopicPublisher.publish(javax.jms.Topic, javax.jms.Message, int, int, long)
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.