public class JMSConsumerImpl
extends java.lang.Object
Constructor and Description |
---|
JMSConsumerImpl(JMSContextImpl jmsContext,
MessageConsumer consumer) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
MessageListener |
getMessageListener() |
java.lang.String |
getMessageSelector() |
Message |
receive() |
Message |
receive(long timeout) |
<T> T |
receiveBody(java.lang.Class<T> c) |
<T> T |
receiveBody(java.lang.Class<T> c,
long timeout) |
<T> T |
receiveBodyNoWait(java.lang.Class<T> c) |
Message |
receiveNoWait() |
void |
setMessageListener(MessageListener listener) |
public JMSConsumerImpl(JMSContextImpl jmsContext, MessageConsumer consumer)
public java.lang.String getMessageSelector()
public MessageListener getMessageListener() throws JMSRuntimeException
JMSRuntimeException
public void setMessageListener(MessageListener listener) throws JMSRuntimeException
JMSRuntimeException
public Message receive()
public Message receive(long timeout)
public Message receiveNoWait()
public void close()
public <T> T receiveBody(java.lang.Class<T> c)
public <T> T receiveBody(java.lang.Class<T> c, long timeout)
public <T> T receiveBodyNoWait(java.lang.Class<T> c)