org.apache.qpid.client
Class TopicSubscriberAdaptor<C extends BasicMessageConsumer>

java.lang.Object
  extended by org.apache.qpid.client.TopicSubscriberAdaptor<C>
All Implemented Interfaces:
MessageConsumer, TopicSubscriber

 class TopicSubscriberAdaptor<C extends BasicMessageConsumer>
extends Object
implements TopicSubscriber

Wraps a MessageConsumer to fulfill the extended TopicSubscriber contract


Constructor Summary
TopicSubscriberAdaptor(Topic topic, C consumer)
           
TopicSubscriberAdaptor(Topic topic, C consumer, boolean noLocal)
           
 
Method Summary
 void addBindingKey(Topic topic, String bindingKey)
           
 void close()
           
(package private)  C getMessageConsumer()
           
 MessageListener getMessageListener()
           
 String getMessageSelector()
           
 boolean getNoLocal()
           
 Topic getTopic()
           
 Message receive()
           
 Message receive(long l)
           
 Message receiveNoWait()
           
 void setMessageListener(MessageListener messageListener)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TopicSubscriberAdaptor

TopicSubscriberAdaptor(Topic topic,
                       C consumer,
                       boolean noLocal)

TopicSubscriberAdaptor

TopicSubscriberAdaptor(Topic topic,
                       C consumer)
Method Detail

getTopic

public Topic getTopic()
               throws JMSException
Specified by:
getTopic in interface TopicSubscriber
Throws:
JMSException

getNoLocal

public boolean getNoLocal()
                   throws JMSException
Specified by:
getNoLocal in interface TopicSubscriber
Throws:
JMSException

getMessageSelector

public String getMessageSelector()
                          throws JMSException
Specified by:
getMessageSelector in interface MessageConsumer
Throws:
JMSException

getMessageListener

public MessageListener getMessageListener()
                                   throws JMSException
Specified by:
getMessageListener in interface MessageConsumer
Throws:
JMSException

setMessageListener

public void setMessageListener(MessageListener messageListener)
                        throws JMSException
Specified by:
setMessageListener in interface MessageConsumer
Throws:
JMSException

receive

public Message receive()
                throws JMSException
Specified by:
receive in interface MessageConsumer
Throws:
JMSException

receive

public Message receive(long l)
                throws JMSException
Specified by:
receive in interface MessageConsumer
Throws:
JMSException

receiveNoWait

public Message receiveNoWait()
                      throws JMSException
Specified by:
receiveNoWait in interface MessageConsumer
Throws:
JMSException

close

public void close()
           throws JMSException
Specified by:
close in interface MessageConsumer
Throws:
JMSException

getMessageConsumer

C getMessageConsumer()

addBindingKey

public void addBindingKey(Topic topic,
                          String bindingKey)
                   throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException


Licensed to the Apache Software Foundation