Package org.ow2.joram.jakarta.connector

Class OutboundPublisher

java.lang.Object

org.ow2.joram.jakarta.connector.OutboundProducer

org.ow2.joram.jakarta.connector.OutboundPublisher

All Implemented Interfaces:

jakarta.jms.MessageProducer, jakarta.jms.TopicPublisher, AutoCloseable

public class OutboundPublisher
extends OutboundProducer
implements jakarta.jms.TopicPublisher

An OutboundPublisher instance wraps a JMS producer for a component involved in PubSub outbound messaging.

Field Summary

Fields

Modifier and Type	Field	Description
private static boolean	DEBUG
private static Logger	logger

Fields inherited from class org.ow2.joram.jakarta.connector.OutboundProducer

producer, session, valid

Constructor Summary

Constructors

Constructor	Description
OutboundPublisher(jakarta.jms.MessageProducer producer, OutboundSession session)	Constructs an OutboundPublisher instance.

Method Summary

Modifier and Type	Method	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.

Methods inherited from class org.ow2.joram.jakarta.connector.OutboundProducer

checkValidity, close, getDeliveryDelay, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, send, send, send, send, send, send, setDeliveryDelay, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface jakarta.jms.MessageProducer

close, getDeliveryDelay, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, send, send, send, send, send, send, setDeliveryDelay, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive

Field Detail

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

Constructor Detail

OutboundPublisher

OutboundPublisher(jakarta.jms.MessageProducer producer,
                  OutboundSession session)

Constructs an OutboundPublisher instance.

Parameters:

producer - The JMS producer to wrap.

session - The OutboundSession the publisher belongs to.

Method Detail

getTopic

public jakarta.jms.Topic getTopic()
                           throws jakarta.jms.JMSException

Delegates the call to the wrapped producer.

Specified by:

getTopic in interface jakarta.jms.TopicPublisher

Throws:

jakarta.jms.JMSException

publish

public void publish(jakarta.jms.Message message,
                    int deliveryMode,
                    int priority,
                    long timeToLive)
             throws jakarta.jms.JMSException

Delegates the call to the wrapped producer.

Specified by:

publish in interface jakarta.jms.TopicPublisher

Throws:

jakarta.jms.JMSException

publish

public void publish(jakarta.jms.Message message)
             throws jakarta.jms.JMSException

Delegates the call to the wrapped producer.

Specified by:

publish in interface jakarta.jms.TopicPublisher

Throws:

jakarta.jms.JMSException

publish

public void publish(jakarta.jms.Topic topic,
                    jakarta.jms.Message message,
                    int deliveryMode,
                    int priority,
                    long timeToLive)
             throws jakarta.jms.JMSException

Delegates the call to the wrapped producer.

Specified by:

publish in interface jakarta.jms.TopicPublisher

Throws:

jakarta.jms.JMSException

publish

public void publish(jakarta.jms.Topic topic,
                    jakarta.jms.Message message)
             throws jakarta.jms.JMSException

Delegates the call to the wrapped producer.

Specified by:

publish in interface jakarta.jms.TopicPublisher

Throws:

jakarta.jms.JMSException