public class QueueReceiverAdaptor extends Object implements javax.jms.QueueReceiver
Modifier | Constructor and Description |
---|---|
protected |
QueueReceiverAdaptor(javax.jms.Queue queue,
javax.jms.MessageConsumer consumer) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
javax.jms.MessageListener |
getMessageListener() |
String |
getMessageSelector() |
javax.jms.Queue |
getQueue()
Return the queue associated with this receiver
|
javax.jms.Message |
receive() |
javax.jms.Message |
receive(long l) |
javax.jms.Message |
receiveNoWait() |
void |
setMessageListener(javax.jms.MessageListener messageListener) |
protected QueueReceiverAdaptor(javax.jms.Queue queue, javax.jms.MessageConsumer consumer)
public String getMessageSelector() throws javax.jms.JMSException
getMessageSelector
in interface javax.jms.MessageConsumer
javax.jms.JMSException
public javax.jms.MessageListener getMessageListener() throws javax.jms.JMSException
getMessageListener
in interface javax.jms.MessageConsumer
javax.jms.JMSException
public void setMessageListener(javax.jms.MessageListener messageListener) throws javax.jms.JMSException
setMessageListener
in interface javax.jms.MessageConsumer
javax.jms.JMSException
public javax.jms.Message receive() throws javax.jms.JMSException
receive
in interface javax.jms.MessageConsumer
javax.jms.JMSException
public javax.jms.Message receive(long l) throws javax.jms.JMSException
receive
in interface javax.jms.MessageConsumer
javax.jms.JMSException
public javax.jms.Message receiveNoWait() throws javax.jms.JMSException
receiveNoWait
in interface javax.jms.MessageConsumer
javax.jms.JMSException
public void close() throws javax.jms.JMSException
close
in interface javax.jms.MessageConsumer
javax.jms.JMSException
public javax.jms.Queue getQueue() throws javax.jms.JMSException
getQueue
in interface javax.jms.QueueReceiver
javax.jms.JMSException
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.