org.apache.qpid.client
Class QueueReceiverAdaptor
java.lang.Object
org.apache.qpid.client.QueueReceiverAdaptor
- All Implemented Interfaces:
- MessageConsumer, QueueReceiver
public class QueueReceiverAdaptor
- extends Object
- implements QueueReceiver
Class that wraps a MessageConsumer for backwards JMS compatibility
Returned by methods in AMQSession etc
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
_consumer
protected MessageConsumer _consumer
_queue
protected Queue _queue
QueueReceiverAdaptor
protected QueueReceiverAdaptor(Queue queue,
MessageConsumer consumer)
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
getQueue
public Queue getQueue()
throws JMSException
- Return the queue associated with this receiver
- Specified by:
getQueue
in interface QueueReceiver
- Returns:
-
- Throws:
JMSException
Licensed to the Apache Software Foundation