Solace JMS Topic Subscriber Hello World

Solace JMS Topic Subscriber Hello World

In this example we will see how to subscriber Solace topic and consume message from newly created Solace Topic using JMS API then please use below sample Hello World program.

Solace JMS version: sol-jms-7.1.2.230

• To run this program you will need below jar:

You will also need below information:

• SOLACE_HOST=tcp://url:portnumber
• SOLACE_VPN=VPN NAME
• JMS-Direct Connection Factory(direct-no Ack back) – Please note: For topic you need JMS-Direct connection factory not JMS-Persistent Connection Factory
• SOLACE_OUTPUT_QUEUE_NAME=queue name
• SOLACE_USERNAME_PUB=user name
• SOLACE_PASSWORD_PUB=password

Sample program:

JavaHonkSolaceTopicSubscriberHelloWorld.java:

package com.javahonk.jms.solace;

import java.util.Hashtable;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.Topic;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

import com.solacesystems.jms.SolJmsUtility;
import com.solacesystems.jms.SupportedProperty;
import com.solacesystems.jms.message.SolBytesMessage;
import com.solacesystems.jms.message.SolTextMessage;

public class JavaHonkSolaceTopicSubscriberHelloWorld {
    
    public static void main(String args[]) throws JMSException, NamingException {       
    	
    	Hashtable<String, Object> env = new Hashtable<String, Object>();
    	env.put(InitialContext.INITIAL_CONTEXT_FACTORY, "com.solacesystems.jndi.SolJNDIInitialContextFactory");
        env.put(InitialContext.PROVIDER_URL, "tcp://URL:PORT NUMBER");
        env.put(SupportedProperty.SOLACE_JMS_VPN, "VPN NAME");
        env.put(Context.SECURITY_PRINCIPAL, "USER NAME");
        env.put(Context.SECURITY_CREDENTIALS, "PASSWORD");
        
        InitialContext initialContext = new InitialContext(env);
        ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("JMS-Direct Connection Factory(direct-no Ack back) name");
        Connection connection = cf.createConnection();

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        Topic topic = session.createTopic("Topic name");

        MessageConsumer consumer = session.createConsumer(topic);
           
        connection.start();
        
        System.out.println("Now waiting for a message. (press Ctrl+C) to terminate anytime");
            
        while (true) {
            
        	Message testMessage = consumer.receive();
            
            System.out.println("Message received:"+((SolTextMessage)testMessage).getText());
            
            if (testMessage instanceof SolBytesMessage) {
            	
            	System.out.println("Message received:"+((SolBytesMessage)testMessage).getMessage());
            	System.out.println("Message size: {} kb"+SolJmsUtility.getMessageSize(testMessage));
            	testMessage.acknowledge();	                 
            }
            
            if (testMessage instanceof SolTextMessage) {
            	
            	System.out.println("Message received:"+((SolTextMessage)testMessage).getText());
            	System.out.println("Message size: {} kb"+SolJmsUtility.getMessageSize(testMessage));
            	testMessage.acknowledge();
            }
        }
    }
}

Reference:

• Solace publisher queue