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