public class OutboundSubscriber extends OutboundConsumer implements TopicSubscriber
OutboundSubscriber
instance wraps a JMS PubSub consumer
for a component involved in outbound messaging.Modifier and Type | Field and Description |
---|---|
static Logger |
logger |
private boolean |
noLocal
NoLocal parameter.
|
private Topic |
topic
Topic instance to consume messages from.
|
consumer, session, valid
Constructor and Description |
---|
OutboundSubscriber(Topic topic,
boolean noLocal,
MessageConsumer consumer,
OutboundSession session)
Constructs an
OutboundSubscriber instance. |
Modifier and Type | Method and Description |
---|---|
boolean |
getNoLocal()
Returns the noLocal parameter.
|
Topic |
getTopic()
Returns the consumer's topic.
|
checkValidity, close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener
public static Logger logger
private Topic topic
private boolean noLocal
OutboundSubscriber(Topic topic, boolean noLocal, MessageConsumer consumer, OutboundSession session)
OutboundSubscriber
instance.public Topic getTopic() throws JMSException
getTopic
in interface TopicSubscriber
JMSException
public boolean getNoLocal() throws JMSException
getNoLocal
in interface TopicSubscriber
JMSException
Copyright © 2023 ScalAgent D.T.. All rights reserved.