public class QpidRAMessageConsumer extends Object implements javax.jms.MessageConsumer
Modifier and Type | Field and Description |
---|---|
protected javax.jms.MessageConsumer |
_consumer
The wrapped message consumer
|
protected QpidRASessionImpl |
_session
The session for this consumer
|
Constructor and Description |
---|
QpidRAMessageConsumer(javax.jms.MessageConsumer consumer,
QpidRASessionImpl session)
Create a new wrapper
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Close
|
javax.jms.MessageListener |
getMessageListener()
Get message listener
|
String |
getMessageSelector()
Get message selector
|
javax.jms.Message |
receive()
Receive
|
javax.jms.Message |
receive(long timeout)
Receive
|
javax.jms.Message |
receiveNoWait()
Receive
|
void |
setMessageListener(javax.jms.MessageListener listener)
Set message listener
|
protected javax.jms.MessageConsumer _consumer
protected QpidRASessionImpl _session
public QpidRAMessageConsumer(javax.jms.MessageConsumer consumer, QpidRASessionImpl session)
consumer
- the consumersession
- the sessionpublic void close() throws javax.jms.JMSException
close
in interface javax.jms.MessageConsumer
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.MessageListener getMessageListener() throws javax.jms.JMSException
getMessageListener
in interface javax.jms.MessageConsumer
javax.jms.JMSException
- Thrown if an error occurspublic void setMessageListener(javax.jms.MessageListener listener) throws javax.jms.JMSException
setMessageListener
in interface javax.jms.MessageConsumer
listener
- The listenerjavax.jms.JMSException
- Thrown if an error occurspublic String getMessageSelector() throws javax.jms.JMSException
getMessageSelector
in interface javax.jms.MessageConsumer
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.Message receive() throws javax.jms.JMSException
receive
in interface javax.jms.MessageConsumer
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.Message receive(long timeout) throws javax.jms.JMSException
receive
in interface javax.jms.MessageConsumer
timeout
- The timeout valuejavax.jms.JMSException
- Thrown if an error occurspublic javax.jms.Message receiveNoWait() throws javax.jms.JMSException
receiveNoWait
in interface javax.jms.MessageConsumer
javax.jms.JMSException
- Thrown if an error occursCopyright © 2006–2016 The Apache Software Foundation. All rights reserved.