Package org.ow2.joram.jakarta.connector

Class OutboundSubscriber

java.lang.Object

org.ow2.joram.jakarta.connector.OutboundConsumer

org.ow2.joram.jakarta.connector.OutboundSubscriber

All Implemented Interfaces:

jakarta.jms.MessageConsumer, jakarta.jms.TopicSubscriber, AutoCloseable

public class OutboundSubscriber
extends OutboundConsumer
implements jakarta.jms.TopicSubscriber

An OutboundSubscriber instance wraps a JMS PubSub consumer for a component involved in outbound messaging.

Field Summary

Fields

Modifier and Type	Field	Description
private static boolean	DEBUG
private static Logger	logger
private boolean	noLocal	NoLocal parameter.
private jakarta.jms.Topic	topic	Topic instance to consume messages from.

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

consumer, session, valid

Constructor Summary

Constructors

Constructor	Description
OutboundSubscriber(jakarta.jms.Topic topic, boolean noLocal, jakarta.jms.MessageConsumer consumer, OutboundSession session)	Constructs an OutboundSubscriber instance.

Method Summary

Modifier and Type	Method	Description
boolean	getNoLocal()	Returns the noLocal parameter.
jakarta.jms.Topic	getTopic()	Returns the consumer's topic.

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

checkValidity, close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener

Methods inherited from class java.lang.Object

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

Methods inherited from interface jakarta.jms.MessageConsumer

close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener

Field Detail

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

topic

private jakarta.jms.Topic topic

Topic instance to consume messages from.

noLocal

private boolean noLocal

NoLocal parameter.

Constructor Detail

OutboundSubscriber

OutboundSubscriber(jakarta.jms.Topic topic,
                   boolean noLocal,
                   jakarta.jms.MessageConsumer consumer,
                   OutboundSession session)

Constructs an OutboundSubscriber instance.

Method Detail

getTopic

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

Returns the consumer's topic.

Specified by:

getTopic in interface jakarta.jms.TopicSubscriber

Throws:

jakarta.jms.JMSException

getNoLocal

public boolean getNoLocal()
                   throws jakarta.jms.JMSException

Returns the noLocal parameter.

Specified by:

getNoLocal in interface jakarta.jms.TopicSubscriber

Throws:

jakarta.jms.JMSException