public class JMSConsumer extends Object implements javax.jms.JMSConsumer
Modifier and Type | Field and Description |
---|---|
private javax.jms.MessageConsumer |
consumer |
Constructor and Description |
---|
JMSConsumer(javax.jms.MessageConsumer consumer)
API method
|
Modifier and Type | Method and Description |
---|---|
void |
close()
API method
|
javax.jms.MessageListener |
getMessageListener()
API method
|
String |
getMessageSelector()
API method
|
javax.jms.Message |
receive()
API method
|
javax.jms.Message |
receive(long timeout)
API method
|
<T> T |
receiveBody(Class<T> c)
API method
|
<T> T |
receiveBody(Class<T> c,
long timeout)
API method
|
<T> T |
receiveBodyNoWait(Class<T> c)
API method
|
javax.jms.Message |
receiveNoWait()
API method
|
void |
setMessageListener(javax.jms.MessageListener listener)
API method
|
public void close()
close
in interface AutoCloseable
close
in interface javax.jms.JMSConsumer
public javax.jms.MessageListener getMessageListener() throws javax.jms.JMSRuntimeException
getMessageListener
in interface javax.jms.JMSConsumer
javax.jms.JMSRuntimeException
public String getMessageSelector()
getMessageSelector
in interface javax.jms.JMSConsumer
public javax.jms.Message receive()
receive
in interface javax.jms.JMSConsumer
public javax.jms.Message receive(long timeout)
receive
in interface javax.jms.JMSConsumer
public <T> T receiveBody(Class<T> c)
receiveBody
in interface javax.jms.JMSConsumer
public <T> T receiveBody(Class<T> c, long timeout)
receiveBody
in interface javax.jms.JMSConsumer
public <T> T receiveBodyNoWait(Class<T> c)
receiveBodyNoWait
in interface javax.jms.JMSConsumer
public javax.jms.Message receiveNoWait()
receiveNoWait
in interface javax.jms.JMSConsumer
public void setMessageListener(javax.jms.MessageListener listener) throws javax.jms.JMSRuntimeException
setMessageListener
in interface javax.jms.JMSConsumer
javax.jms.JMSRuntimeException
Copyright © 2018 ScalAgent D.T.. All Rights Reserved.