public class OutboundSubscriber extends OutboundConsumer implements javax.jms.TopicSubscriber
OutboundSubscriber
instance wraps a JMS PubSub consumer
for a component involved in outbound messaging.Modifier and Type | Field and Description |
---|---|
static org.objectweb.util.monolog.api.Logger |
logger |
private boolean |
noLocal
NoLocal parameter.
|
private javax.jms.Topic |
topic
Topic instance to consume messages from.
|
consumer, session, valid
Constructor and Description |
---|
OutboundSubscriber(javax.jms.Topic topic,
boolean noLocal,
javax.jms.MessageConsumer consumer,
OutboundSession session)
Constructs an
OutboundSubscriber instance. |
Modifier and Type | Method and Description |
---|---|
boolean |
getNoLocal()
Returns the noLocal parameter.
|
javax.jms.Topic |
getTopic()
Returns the consumer's topic.
|
checkValidity, close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener
public static org.objectweb.util.monolog.api.Logger logger
private javax.jms.Topic topic
private boolean noLocal
OutboundSubscriber(javax.jms.Topic topic, boolean noLocal, javax.jms.MessageConsumer consumer, OutboundSession session)
OutboundSubscriber
instance.public javax.jms.Topic getTopic() throws javax.jms.JMSException
getTopic
in interface javax.jms.TopicSubscriber
javax.jms.JMSException
public boolean getNoLocal() throws javax.jms.JMSException
getNoLocal
in interface javax.jms.TopicSubscriber
javax.jms.JMSException
Copyright © 2018 ScalAgent D.T.. All Rights Reserved.