TopicRequestor

 

---

public class 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 can allocate some resources outside the JVM on behalf of a TopicRequestor, 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 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.