public class OutboundPublisher extends OutboundProducer implements javax.jms.TopicPublisher
OutboundPublisher
instance wraps a JMS producer
for a component involved in PubSub outbound messaging.Modifier and Type | Field and Description |
---|---|
static org.objectweb.util.monolog.api.Logger |
logger |
producer, session, valid
Constructor and Description |
---|
OutboundPublisher(javax.jms.MessageProducer producer,
OutboundSession session)
Constructs an
OutboundPublisher instance. |
Modifier and Type | Method and Description |
---|---|
javax.jms.Topic |
getTopic()
Delegates the call to the wrapped producer.
|
void |
publish(javax.jms.Message message)
Delegates the call to the wrapped producer.
|
void |
publish(javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
Delegates the call to the wrapped producer.
|
void |
publish(javax.jms.Topic topic,
javax.jms.Message message)
Delegates the call to the wrapped producer.
|
void |
publish(javax.jms.Topic topic,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
Delegates the call to the wrapped producer.
|
checkValidity, 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
OutboundPublisher(javax.jms.MessageProducer producer, OutboundSession session)
OutboundPublisher
instance.producer
- The JMS producer to wrap.session
- The OutboundSession the publisher belongs to.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, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
publish
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.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
public void publish(javax.jms.Topic topic, javax.jms.Message message) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
javax.jms.JMSException
Copyright © 2018 ScalAgent D.T.. All Rights Reserved.