public class OutboundPublisher extends OutboundProducer implements 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(MessageProducer producer,
OutboundSession session)
Constructs an
OutboundPublisher instance. |
Modifier and Type | Method and Description |
---|---|
Topic |
getTopic()
Delegates the call to the wrapped producer.
|
void |
publish(Message message)
Delegates the call to the wrapped producer.
|
void |
publish(Message message,
int deliveryMode,
int priority,
long timeToLive)
Delegates the call to the wrapped producer.
|
void |
publish(Topic topic,
Message message)
Delegates the call to the wrapped producer.
|
void |
publish(Topic topic,
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, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive
OutboundPublisher(MessageProducer producer, OutboundSession session)
OutboundPublisher
instance.producer
- The JMS producer to wrap.session
- The OutboundSession the publisher belongs to.public Topic getTopic() throws JMSException
getTopic
in interface TopicPublisher
JMSException
public void publish(Message message, int deliveryMode, int priority, long timeToLive) throws JMSException
publish
in interface TopicPublisher
JMSException
public void publish(Message message) throws JMSException
publish
in interface TopicPublisher
JMSException
public void publish(Topic topic, Message message, int deliveryMode, int priority, long timeToLive) throws JMSException
publish
in interface TopicPublisher
JMSException
public void publish(Topic topic, Message message) throws JMSException
publish
in interface TopicPublisher
JMSException
Copyright © 2013 ScalAgent D.T.. All Rights Reserved.