Creating a Message Producer and Consumer for a Topic 

Use

To send messages to a certain topic, you have to create a topic publisher. 

Procedure

Creating a Message Producer

Create a topic publisher using the following code:

TopicPublisher topicPublisher =                topicSession.createTopicPublisher(topic);

For more information, see Topic Publisher Example.

Creating a Message Consumer

Here we refer to synchronous and asynchronous to describe how a JMS consumer application receives messages. The overall JMS client-to-client communication process itself is always asynchronous, since the producer application only waits until the message is received by the JMS Provider, not until the message is successfully received and processed by the consumer, to complete its next task.

You can use the TopicSubscriber in two ways:

●      If you want to receive messages asynchronously, you must register the class as a MessageListener instance. This enables you to receive the messages in the onMessage(Message) method:

// create subscriber to a topic TopicSubscriber topicSubscriber = topicSession.createSubscriber(topic);   // set message listener topicSubscriber.setMessageListener(this);   public void onMessage(javax.jms.Message message) { // process the message

For an example of receiving messages asynchronously, see Asynchronously Receiving Messages Sent to a Topic.

●      If you want to receive messages synchronously, use the receive() method.

// create subscriber to a topic TopicSubscriber topicSubscriber = topicSession.createSubscriber(topic);           // receive a text message TextMessage textMessage = (TextMessage) topicSubscriber.receive();

For an example of receiving messages synchronously, see Synchronously Receiving Messages Sent to a Topic.