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