Register Now for EDA Summit 2024 - Virtual EventRegister for Free

Durable JMS Subscription

1 Minute Read

This feature introduction shows how to create a Durable JMS Subscription using Apache Qpid JMS 2.0 API over AMQP 1.0. Solace messaging is used as the message broker. In Solace messaging, durable JMS subscriptions are implemented using Durable Topic Endpoints (DTEs).

The example code illustrates the Subscriber in the publish/subscribe messaging pattern.

Feature Overview

A durable subscription is used by an application that needs to receive all the messages published on a topic, including the ones published when there is no consumer associated with it.

Code

To create a durable subscription, you must first create a JMS connection as with all JMS samples. See the publish/subscribe tutorial for more details if you need.

A durable subscription requires that you create a durable consumer given a subscription name and topic. The subscription name will be the name used for the Durable Topic Endpoint in the Solace PubSub+ messaging service and the topic name is what will attract the messages you wish to receive.

One aspect that is unusual with Qpid JMS is that a client ID is required to create a durable consumer. Therefore, you must set this on the context. Keep in mind that client IDs must be unique within the Solace PubSub+ messaging service.

The following code snippet outlines this.

ConnectionFactory connectionFactory = new JmsConnectionFactory(SOLACE_USERNAME, SOLACE_PASSWORD, SOLACE_HOST);
JMSContext context = connectionFactory.createContext()
context.setClientID(CLIENT_ID);
Topic topic = context.createTopic(TOPIC_NAME);
String message = context.createDurableConsumer(topic, SUBSCRIPTION_NAME).receiveBody(String.class);

Learn More