org.apache.qpid.client
Class QueueReceiverAdaptor

java.lang.Object
  extended by 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


Field Summary
protected  MessageConsumer _consumer
           
protected  Queue _queue
           
 
Constructor Summary
protected QueueReceiverAdaptor(Queue queue, MessageConsumer consumer)
           
 
Method Summary
 void close()
           
 MessageListener getMessageListener()
           
 String getMessageSelector()
           
 Queue getQueue()
          Return the queue associated with this receiver
 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
 

Field Detail

_consumer

protected MessageConsumer _consumer

_queue

protected Queue _queue
Constructor Detail

QueueReceiverAdaptor

protected QueueReceiverAdaptor(Queue queue,
                               MessageConsumer consumer)
Method Detail

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