QueueRequestor

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

JMS provides this QueueRequestor helper class to simplify 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 may allocate some resources outside of the JVM on behalf of a QueueRequestor, clients should close them when they are not needed. You cannot rely on garbage collection to reclaim these resources eventually, because this may 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 per request is expected.

Parameters:

message - the message to send.

Returns:

the reply message.

Throws:

JMSException - if a JMS error occurs.