org.apache.qpid.client
Class TopicSubscriberAdaptor<C extends BasicMessageConsumer>
java.lang.Object
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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TopicSubscriberAdaptor
TopicSubscriberAdaptor(Topic topic,
C consumer,
boolean noLocal)
TopicSubscriberAdaptor
TopicSubscriberAdaptor(Topic topic,
C consumer)
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