public class HornetQRATopicPublisher extends HornetQRAMessageProducer implements javax.jms.TopicPublisher
producer, session
Constructor and Description |
---|
HornetQRATopicPublisher(javax.jms.TopicPublisher producer,
HornetQRASession 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 HornetQRATopicPublisher(javax.jms.TopicPublisher producer, HornetQRASession 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 JBoss, a division of Red Hat. All rights reserved.