TopicRequestor

extends java.lang.Object

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

JMS provides this TopicRequestor class to assist with making service requests.

The TopicRequestor constructor is given a non-transacted TopicSession and a destination Topic. It creates a TemporaryTopic 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.

Constructors

TopicRequestor

public TopicRequestor(TopicSession session,
                      Topic topic) throws JMSException

Constructor for the TopicRequestor class. This implementation assumes that the session parameter is non-transacted, and either AUTO_ACKNOWLEDGE or DUPS_OK_ACKNOWLEDGE.

Parameters:

• session - the topic session the topic belongs to.
• topic - the topic 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 TopicRequestor, 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 TopicRequestor constructor.

Throws:

JMSException - if a JMS error occurs.

request

public Message request(Message message) throws JMSException

Send a request and wait for a reply.

Parameters:

message - the message to send.

Returns:

the reply message.

Throws:

JMSException - if a JMS error occurs.