public class ActiveMQRATopicPublisher extends ActiveMQRAMessageProducer implements javax.jms.TopicPublisher
producer, session
Constructor and Description |
---|
ActiveMQRATopicPublisher(javax.jms.TopicPublisher producer,
ActiveMQRASession session)
Create a new wrapper
|
Modifier and Type | Method and Description |
---|---|
javax.jms.Topic |
getTopic()
Get the topic
|
void |
publish(javax.jms.Message message)
Publish message
|
void |
publish(javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
Publish message
|
void |
publish(javax.jms.Topic destination,
javax.jms.Message message)
Publish message
|
void |
publish(javax.jms.Topic destination,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
Publish message
|
close, getDeliveryDelay, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, send, send, send, send, send, send, setDeliveryDelay, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, getDeliveryDelay, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, send, send, send, send, send, send, setDeliveryDelay, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive
public ActiveMQRATopicPublisher(javax.jms.TopicPublisher producer, ActiveMQRASession session)
producer
- the producersession
- the sessionpublic javax.jms.Topic getTopic() throws javax.jms.JMSException
getTopic
in interface javax.jms.TopicPublisher
javax.jms.JMSException
- Thrown if an error occurspublic void publish(javax.jms.Message message, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
message
- The messagedeliveryMode
- The delivery modepriority
- The prioritytimeToLive
- The time to livejavax.jms.JMSException
- Thrown if an error occurspublic void publish(javax.jms.Message message) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
message
- The messagejavax.jms.JMSException
- Thrown if an error occurspublic void publish(javax.jms.Topic destination, javax.jms.Message message, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
destination
- The destinationmessage
- The messagedeliveryMode
- The delivery modepriority
- The prioritytimeToLive
- The time to livejavax.jms.JMSException
- Thrown if an error occurspublic void publish(javax.jms.Topic destination, javax.jms.Message message) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
destination
- The destinationmessage
- The messagejavax.jms.JMSException
- Thrown if an error occursCopyright © 2016 The Apache Software Foundation. All rights reserved.