QueueRequestor

 

---

public class QueueRequestor
extends java.lang.Object

java.lang.Object | +----javax.jms.QueueRequestor

The QueueRequestor helper class simplifies making service requests.
The QueueRequestor constructor is given a non-transacted QueueSession and a destination Queue. It creates a TemporaryQueue for the responses, and provides a request() method that sends the request message and waits for its reply.
Users are free to create more sophisticated versions.

See also: TopicRequestor

 

Constructors

QueueRequestor

public QueueRequestor(QueueSession session,
                      Queue queue) 
                              throws JMSException

This implementation assumes that the session parameter is non-transacted and either AUTO_ACKNOWLEDGE or DUPS_OK_ACKNOWLEDGE.

Parameters:

• session: the queue session the queue belongs to.

• queue: the queue to perform the request/reply call on.

Throws:

JMSException if a JMS error occurs.

 

Methods

close

public void close() throws JMSException

Because a provider can allocate some resources outside the JVM on behalf of a QueueRequestor, clients must close them when they are not needed. You cannot rely on garbage collection to reclaim these resources eventually, because this might not occur soon enough.

Note:

This method closes the session object passed to the QueueRequestor constructor.

Throws:

JMSException if a JMS error occurs.

request

public Message request(Message message)
                                  throws JMSException

Send a request and wait for a reply. The temporary queue is used for replyTo, and only one reply is expected for each request.

Parameters:

message: the message to send.

Returns:

The reply message.

Throws:

JMSException if a JMS error occurs.