org.objectweb.joram.client.connector
Class OutboundSubscriber

java.lang.Object
  extended by org.objectweb.joram.client.connector.OutboundConsumer
      extended by 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.
 
Fields inherited from class org.objectweb.joram.client.connector.OutboundConsumer
consumer, session, valid
 
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 org.objectweb.joram.client.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 javax.jms.MessageConsumer
close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener
 

Field Detail

topic

private javax.jms.Topic topic
Topic instance to consume messages from.


noLocal

private boolean noLocal
NoLocal parameter.

Constructor Detail

OutboundSubscriber

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

Method Detail

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.