JBOSS JMS – SENDER & LISTENER A TOPIC

1.       Create a Java project and set up lib as below images

Note: Must be correct libs and location of libs

2.       Create 2 classes as below code

Listener Class

/*

Use source code downloads, example commands,

and any other techniques at your own risk.

No warranty is provided.

*/

import java.util.Properties;

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.MessageListener;

import javax.jms.TextMessage;

import javax.jms.Topic;

import javax.jms.TopicConnection;

import javax.jms.TopicConnectionFactory;

import javax.jms.TopicSession;

import javax.jms.TopicSubscriber;

import javax.naming.Context;

import javax.naming.InitialContext;

import javax.naming.NamingException;

public class Listener implements MessageListener {

                String url_;

                String name_;

                TopicConnection conn = null;

                TopicSession session = null;

                Topic topic = null;

                public Listener(String url, String name) {

                                super();

                                url_ = url;

                                name_ = name;

                                try {

                                                this.initializeListener();

                                } catch (Exception e) {

                                                System.out.println("Error creating listener: " + e);

                                                e.printStackTrace();

                                }

                }

                public void onMessage(Message msg) {

                                TextMessage tm = (TextMessage) msg;

                                try {

                                                System.out.println("Incoming message: " + tm.getText());

                                } catch (Exception e) {

                                                e.printStackTrace();

                                }

                }

                private void initializeListener() throws JMSException, NamingException {

                                Properties props = new Properties();

                props.setProperty(Context.INITIAL_CONTEXT_FACTORY,"org.jnp.interfaces.NamingContextFactory");

                                props.setProperty(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces");

                                props.setProperty(Context.PROVIDER_URL, url_);

                                props.setProperty(Context.SECURITY_CREDENTIALS, "bms");

                                props.setProperty(Context.SECURITY_AUTHENTICATION, "bms");

                                Context context = new InitialContext(props);

                                System.out.println("performing lookup...");

                                Object tmp = context.lookup("ConnectionFactory");

                                System.out.println("lookup completed, making topic");

                                TopicConnectionFactory tcf = (TopicConnectionFactory) tmp;

                                conn = tcf.createTopicConnection("bms","bms");

                                topic = (Topic) context.lookup(name_);

                                session = conn.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE);

                                conn.start();

                                TopicSubscriber recv = session.createSubscriber(topic);

                                recv.setMessageListener(this);

                }

                public void disconnect() throws JMSException {

                                if(conn != null) {

                                                conn.stop();

                                }

                                if(session != null) {

                                                session.close();

                                }

                                if(conn != null) {

                                                conn.close();

                                }

                }

                public static void main(String args[]) {

                                System.out.println("Starting JMS Example Listener");

                                System.out.println("Program will be active for 1 minute.");

                                //change these values to your situtation:

                                Listener listener = new Listener("jnp://10.26.72.56:1099", "/jms/bms/NonlinearDataUpdateNotificationTopic");

                                //leave it open for 2 minutes:

                                try {

                                                Thread.sleep(120000);

                                } catch(Exception e) {

                                                System.out.println("Error sleeping: " + e);

                                                e.printStackTrace();

                                }

                                try {

                                                listener.disconnect();

                                } catch(Exception e) {

                                                System.out.println("Error terminating listener JMS objects: " + e);

                                                e.printStackTrace();

                                }

                                System.out.println("Done listening");

                }

}

Sender Class

/*

Use source code downloads, example commands,

and any other techniques at your own risk.

No warranty is provided.

*/

import java.util.Properties;

import javax.jms.JMSException;

import javax.jms.TextMessage;

import javax.jms.Topic;

import javax.jms.TopicConnection;

import javax.jms.TopicConnectionFactory;

import javax.jms.TopicPublisher;

import javax.jms.TopicSession;

import javax.naming.Context;

import javax.naming.InitialContext;

import javax.naming.NamingException;

public class Sender {

                String url_;

                String name_;

                TopicConnection conn = null;

                TopicSession session = null;

                Topic topic = null;

                public Sender(String url, String name) throws JMSException, NamingException {

                                url_ = url;

                                name_ = name;

                                this.initializeSender();

                }

                private void initializeSender() throws JMSException, NamingException {

                                Properties props = new Properties();                                                                                     props.setProperty(Context.INITIAL_CONTEXT_FACTORY,"org.jnp.interfaces.NamingContextFactory");

                                props.setProperty(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces");

                                props.setProperty(Context.PROVIDER_URL, url_);

                                props.setProperty(Context.SECURITY_CREDENTIALS, "bms");

                                props.setProperty(Context.SECURITY_AUTHENTICATION, "bms");

                                Context context = new InitialContext(props);

                                TopicConnectionFactory tcf = (TopicConnectionFactory) context.lookup("ConnectionFactory");

                                conn = tcf.createTopicConnection("bms","bms");

                                topic = (Topic) context.lookup(name_);

                                session = conn.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE);

                                conn.start();

                }

                 public void send(String text) throws JMSException, NamingException {

                     // Send a text msg

                                 try {

                     TopicPublisher send = session.createPublisher(topic);

                     TextMessage tm = session.createTextMessage(text);

                     send.publish(tm);

                     send.close();

                                 }

                                 catch (Exception e) {

                                                 System.out.println(e.getMessage());

                                 }

                 }

                public void disconnect() throws JMSException {

                                if(conn != null) {

                                                conn.stop();

                                }

                                if(session != null) {

                                                session.close();

                                }

                                if(conn != null) {

                                                conn.close();

                                }

                }

                public String getTopicName() {

                                return name_;

                }

                public String getTopicURL() {

                                return url_;

                }

                public static void main(String args[]) throws Exception {

                                System.out.println("Starting JMS Example Sender");

                Sender sender = new Sender("jnp://10.26.72.56:1099", "/jms/bms/NonlinearDataUpdateNotificationTopic");

                System.out.println("Sending list of Adam Sandler Movies " + sender.url_);

                sender.send("Schedule 1995");

                sender.send("Schedule 1996");

                sender.send("Schedule 1998");

                sender.send("Schedule 1999");

                sender.send("Schedule 2002");

                sender.send("Schedule 2004");

sender.send("Schedule 2003");

                sender.disconnect();

System.out.println("JMS Example Sender Complete - list sent");

     }

}