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