Package org.ow2.joram.jakarta.jms

Class JMSConsumer

java.lang.Object

org.ow2.joram.jakarta.jms.JMSConsumer

All Implemented Interfaces:

jakarta.jms.JMSConsumer, AutoCloseable

public class JMSConsumer
extends Object
implements jakarta.jms.JMSConsumer

Field Summary

Fields

Modifier and Type	Field	Description
private jakarta.jms.MessageConsumer	consumer

Constructor Summary

Constructors

Constructor	Description
JMSConsumer(jakarta.jms.MessageConsumer consumer)	API method

Method Summary

Modifier and Type	Method	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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

consumer

private jakarta.jms.MessageConsumer consumer

Constructor Detail

JMSConsumer

public JMSConsumer(jakarta.jms.MessageConsumer consumer)

API method

Method Detail

close

public void close()

API method

Specified by:

close in interface AutoCloseable

Specified by:

close in interface jakarta.jms.JMSConsumer

getMessageListener

public jakarta.jms.MessageListener getMessageListener()
                                               throws jakarta.jms.JMSRuntimeException

API method

Specified by:

getMessageListener in interface jakarta.jms.JMSConsumer

Throws:

jakarta.jms.JMSRuntimeException

getMessageSelector

public String getMessageSelector()

API method

Specified by:

getMessageSelector in interface jakarta.jms.JMSConsumer

receive

public jakarta.jms.Message receive()

API method

Specified by:

receive in interface jakarta.jms.JMSConsumer

receive

public jakarta.jms.Message receive(long timeout)

API method

Specified by:

receive in interface jakarta.jms.JMSConsumer

receiveBody

public <T> T receiveBody(Class<T> c)

API method

Specified by:

receiveBody in interface jakarta.jms.JMSConsumer

receiveBody

public <T> T receiveBody(Class<T> c,
                         long timeout)

API method

Specified by:

receiveBody in interface jakarta.jms.JMSConsumer

receiveBodyNoWait

public <T> T receiveBodyNoWait(Class<T> c)

API method

Specified by:

receiveBodyNoWait in interface jakarta.jms.JMSConsumer

receiveNoWait

public jakarta.jms.Message receiveNoWait()

API method

Specified by:

receiveNoWait in interface jakarta.jms.JMSConsumer

setMessageListener

public void setMessageListener(jakarta.jms.MessageListener listener)
                        throws jakarta.jms.JMSRuntimeException

API method

Specified by:

setMessageListener in interface jakarta.jms.JMSConsumer

Throws:

jakarta.jms.JMSRuntimeException