DurableTopicSubscriber.java

/**
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

/**
 *  Apache Qpid JMS 2.0 Solace AMQP Examples: DurableTopicSubscriber
 */

package com.solace.samples.features;

import javax.jms.ConnectionFactory;
import javax.jms.JMSContext;
import javax.jms.Topic;

import org.apache.qpid.jms.JmsConnectionFactory;

/**
* This sample 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).
 *
 * This is the Subscriber in the Publish/Subscribe messaging pattern.
 */
public class DurableTopicSubscriber {

    final String TOPIC_NAME = "T/GettingStarted/pubsub";
    // The JMS Subscription name is the DTE name.
    final String SUBSCRIPTION_NAME = "GettingStarted_DTE";
    final String CLIENT_ID = "GettingStarted";

    private void run(String... args) throws Exception {
        String solaceHost = args[0];
        String solaceUsername = args[1];
        String solacePassword = args[2];
        System.out.printf("DurableTopicSubscriber is connecting to Solace router %s...%n", solaceHost);

        // Programmatically create the connection factory using default settings
        ConnectionFactory connectionFactory = new JmsConnectionFactory(solaceUsername, solacePassword, solaceHost);

        // Establish connection that uses the Solace Message Router as a message broker
        try (JMSContext context = connectionFactory.createContext()) {
        	// Apache Qpid JMS requires an application provided Client Id to create a Durable Consumer.
        	// set the client id on JMS connection
        	context.setClientID(CLIENT_ID);

            System.out.printf("Connected to the Solace router with client username '%s'.%n", solaceUsername);

            // Create the publishing topic programmatically
            Topic topic = context.createTopic(TOPIC_NAME);

            System.out.println("Awaiting message...");
            // create or activate a Durable JMS Subscription
            // create a consumer and wait for a message to arrive.
            // the current thread blocks at the next statement until a message arrives
            String message = context.createDurableConsumer(topic, SUBSCRIPTION_NAME).receiveBody(String.class);

            System.out.printf("Message received: '%s'%n", message);
        }
    }

    public static void main(String[] args) throws Exception {
        if (args.length < 3) {
            System.out.println("Usage: DurableTopicSubscriber amqp://<msg_backbone_ip:amqp_port> <username> <password>");
            System.exit(-1);
        }
        new DurableTopicSubscriber().run(args);
    }
}