org.objectweb.joram.client.connector
Class OutboundSubscriber
java.lang.Object
org.objectweb.joram.client.connector.OutboundConsumer
org.objectweb.joram.client.connector.OutboundSubscriber
- All Implemented Interfaces:
- javax.jms.MessageConsumer, javax.jms.TopicSubscriber
public class OutboundSubscriber
- extends OutboundConsumer
- implements javax.jms.TopicSubscriber
An OutboundSubscriber
instance wraps a JMS PubSub consumer
for a component involved in outbound messaging.
Field Summary |
private boolean |
noLocal
NoLocal parameter. |
private javax.jms.Topic |
topic
Topic instance to consume messages from. |
Constructor Summary |
OutboundSubscriber(javax.jms.Topic topic,
boolean noLocal,
javax.jms.MessageConsumer consumer,
OutboundSession session)
Constructs an OutboundSubscriber instance. |
Method Summary |
boolean |
getNoLocal()
Returns the noLocal parameter. |
javax.jms.Topic |
getTopic()
Returns the consumer's topic. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface javax.jms.MessageConsumer |
close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener |
topic
private javax.jms.Topic topic
- Topic instance to consume messages from.
noLocal
private boolean noLocal
- NoLocal parameter.
OutboundSubscriber
OutboundSubscriber(javax.jms.Topic topic,
boolean noLocal,
javax.jms.MessageConsumer consumer,
OutboundSession session)
- Constructs an
OutboundSubscriber
instance.
getTopic
public javax.jms.Topic getTopic()
throws javax.jms.JMSException
- Returns the consumer's topic.
- Specified by:
getTopic
in interface javax.jms.TopicSubscriber
- Throws:
javax.jms.JMSException
getNoLocal
public boolean getNoLocal()
throws javax.jms.JMSException
- Returns the noLocal parameter.
- Specified by:
getNoLocal
in interface javax.jms.TopicSubscriber
- Throws:
javax.jms.JMSException
Copyright © 2010 ScalAgent D.T.. All Rights Reserved.