Figure 8.10. Client jndi.properties file example

java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory
java.naming.provider.url=localhost:1099
java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces

Figure 8.11. Getting the initial context

// Get the initial context
Context context = new InitialContext();

Figure 8.12. Getting the initial context with specified properties

// Populate with needed properties
Hashtable props = new Hashtable();
props.put(Context.INITIAL_CONTEXT_FACTORY,
  "org.jnp.interfaces.NamingContextFactory");
props.put(Context.PROVIDER_URL, "localhost:1099");
props.put("java.naming.rmi.security.manager", "yes");
props.put(Context.URL_PKG_PREFIXES, "org.jboss.naming");

// Get the initial context with given properties
Context context = new InitialContext(props);

Figure 8.13. Running the manual JNDI example

ant jms-manual-jndi

Figure 8.14. Looking up a TopicConnectionFactory

// Get the connection factory
TopicConnectionFactory topicFactory =
  (TopicConnectionFactory)context.lookup("TopicConnectionFactory");

Figure 8.15. [2.4.1] Looking up a TopicConnectionFactory

// Get the connection factory
TopicConnectionFactory topicFactory =
  (TopicConnectionFactory)context.lookup("ConnectionFactory");

Figure 8.16. Looking up a QueueConnectionFactory

// Get the connection factory
QueueConnectionFactory queueFactory =
  (QueueConnectionFactory)context.lookup("QueueConnectionFactory");

Figure 8.17. [2.4.1] Looking up a QueueConnectionFactory

// Get the connection factory
QueueConnectionFactory queueFactory =
  (QueueConnectionFactory)context.lookup("ConnectionFactory");

Figure 8.18. Creating topic connections and sessions

// Create the connection
topicConnection = topicFactory.createTopicConnection();

// Create the session
topicSession = topicConnection.createTopicSession(
  // No transaction
  false,
  // Auto ack
  Session.AUTO_ACKNOWLEDGE);

Figure 8.19. Creating queue connections and sessions

// Create the connection
queueConnection = queueFactory.createQueueConnection();

// Create the session
queueSession = queueConnection.createQueueSession(
  // No transaction
  false,
  // Auto ack
  Session.AUTO_ACKNOWLEDGE);

Figure 8.20. Looking up a topic destination

// Look up the destination
Topic topic = (Topic)context.lookup("topic/testTopic");

Figure 8.21. Looking up a queue destination

// Look up the destination
Queue queue = (Queue)context.lookup("queue/testQueue");

Figure 8.22. Create a topic publisher

// Create a publisher
TopicPublisher topicPublisher = topicSession.createPublisher(topic);

Figure 8.23. Create a queue sender

// Create a sender
QueueSender queueSender = queueSession.createSender(queue);

Figure 8.24. Create a TextMessage and publish it

// Create a message
TextMessage message = topicSession.createTextMessage();
message.setText(msg);

// Publish the message
topicPublisher.publish(topic, message);

Figure 8.25. Create a TextMessage and send it

// Create a message
TextMessage message = queueSession.createTextMessage();
message.setText(msg);

// Send the message
queueSender.send(queue, message);

Figure 8.26. Complete topic publisher, from HelloPublisher.java in directory org/jboss/docs/jms/client

package org.jboss.docs.jms.client;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

import javax.jms.TopicConnectionFactory;
import javax.jms.TopicConnection;
import javax.jms.TopicSession;
import javax.jms.TopicPublisher;
import javax.jms.Topic;
import javax.jms.TextMessage;
import javax.jms.Session;
import javax.jms.JMSException;
/**
 * <p>Simple JMS client, publish text messages to testTopic Topic.
 * </p>
 *
 * <p><b>NOTE</b>This code is a showcase only. It may not provide
 * a stable production example.</p>
 * @author Peter Antman
 * @version $Revision: 3.1 $
 */
public class HelloPublisher {

  /**
   * Topic connection, hold on to this so you may close it.
   */
  TopicConnection topicConnection;

  /**
   * Topic session, hold on to this so you may close it.
   * Also used to create messages.
   */
  TopicSession topicSession;

  /**
   * Use this to publish messages.
   */
  TopicPublisher topicPublisher;

  /**
   * Destination where to publish.
   */
  Topic topic;


  /**
   * Sets up all the JMS fixtures.
   *
   * Use close() when finished with object.
   *
   * @param factoryJNDI name of the topic connection factory to look up.
   * @param topicJNDI name of the topic destination to look up
   */
  public HelloPublisher(String factoryJNDI, String topicJNDI)
    throws JMSException, NamingException {

    // Get the initial context
    Context context = new InitialContext();

    // Get the connection factory
    TopicConnectionFactory topicFactory =
      (TopicConnectionFactory)context.lookup(factoryJNDI);

    // Create the connection
    topicConnection = topicFactory.createTopicConnection();

    // Create the session
    topicSession = topicConnection.createTopicSession(
      // No transaction
      false,
      // Auto ack
      Session.AUTO_ACKNOWLEDGE);

    // Look up the destination
    topic = (Topic)context.lookup(topicJNDI);

    // Create a publisher
    topicPublisher = topicSession.createPublisher(topic);

  }

  /**
   * Publish the given String as a JMS message to the testTopic topic.
   */
  public void publish(String msg) throws JMSException {

    // Create a message
    TextMessage message = topicSession.createTextMessage();
    message.setText(msg);

    // Publish the message
    topicPublisher.publish(topic, message);

  }

  /**
   * Close session and connection.
   * When done, no publishing is possible any more.
   */
  public void close() throws JMSException {

    topicSession.close();
    topicConnection.close();

  }

  /**
   * Run an example publishing 10 messages to testTopic.
   * Only works up to and including JBoss 2.4.0
   */
  public static void main(String[] args) {
    try {

      // Create the HelloPublisher, giving it the name of the
      // TopicConnection Factory and the Topic destination to
      // use in lookup.
      HelloPublisher publisher = new HelloPublisher(
        // Name of ConnectionFactory
        "TopicConnectionFactory",
        // Name of destination to publish to
        "topic/testTopic");

      // Publish 10 messages
      for (int i = 1; i < 11; i++) {

        String msg = "Hello World no. " + i;
        System.out.println("Publishing message: " + msg);
        publisher.publish(msg);

      }

      // Close down your publisher
      publisher.close();

    } catch(Exception ex) {

      System.err.println(
        "An exception occurred while testing HelloPublisher: " + ex);
      ex.printStackTrace();

    }

  }

} // HelloPublisher

Figure 8.27. [2.4.1] Topic publisher main(), from HelloPublisher25.java in directory org/jboss/docs/jms/client

/**
 * Run an example publishing 10 messages to testTopic.
 * Only works from JBoss 2.4.1 and up.
 */
public static void main(String[] args) {
  try {

    // Create the HelloPublisher, giving it the name of the
    // TopicConnection Factory and the Topic destination to
    // use in lookup.
    HelloPublisher25 publisher = new HelloPublisher25(
      // Name of ConnectionFactory
      "ConnectionFactory",
      // Name of destination to publish to
      "topic/testTopic");

    // Publish 10 messages
    for (int i = 1; i < 11; i++) {

      String msg = "Hello World no. " + i;
      System.out.println("Publishing message: " + msg);
      publisher.publish(msg);

    }

    // Close down your publisher
    publisher.close();

    } catch(Exception ex) {

    System.err.println(
      "An exception occurred while testing HelloPublisher25: " + ex);
    ex.printStackTrace();

  }

}

Figure 8.28. A MessageListener

public class HelloSubscriber implements MessageListener {

  public void onMessage(Message m) {

    // Unpack the message, be careful when casting to the correct
    // message type. onMessage should not throw any application
    // exceptions.
    try {

      String msg = ((TextMessage)m).getText();
      System.out.println("HelloSubscriber got message: " + msg);

    } catch(JMSException ex) {

      System.err.println("Could not get text message: " + ex);
      ex.printStackTrace();

    }

  }

}

Figure 8.29. Create and start a topic subscriber

// Create a subscriber
topicSubscriber = topicSession.createSubscriber(topic);

// Set the message listener, which is this class since we implement
// the MessageListener interface
topicSubscriber.setMessageListener(this);

// OBS! For the message listener to receive any messages the connection
// has to be started.
topicConnection.start();

Figure 8.30. Create and start a queue receiver

// Create a subscriber
queueReceiver = queueSession.createReceiver(queue);

// Set the message listener, which is this class since we
// implement the MessageListener interface
queueReceiver.setMessageListener(this);

// OBS! For the message listener to receive any messages
// the connection has to be started.
queueConnection.start();

Figure 8.31. Topic subscriber example, from HelloSubscriber.java in directory org/jboss/docs/jms/client

package org.jboss.docs.jms.client;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

import javax.jms.TopicConnectionFactory;
import javax.jms.TopicConnection;
import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;
import javax.jms.Topic;
import javax.jms.Message;
import javax.jms.TextMessage;
import javax.jms.Session;
import javax.jms.MessageListener;
import javax.jms.JMSException;

/**
 * <p>Simple JMS client, subscribes for messages on testTopic Topic.
 * </p>
 *
 * <p><b>NOTE</b>This code is a showcase only. It may not provide
 * a stable production example.</p>
 *
 * @author Peter Antman
 * @version $Revision: 3.1 $
 */
public class HelloSubscriber implements MessageListener {

  /**
   * Topic connection, hold on to this so you may close it.
   */
  TopicConnection topicConnection;

  /**
   * Topic session, hold on to this so you may close it.
   * Also used to create messages.
   */
  TopicSession topicSession;

  /**
   * Subscriber
   */
  TopicSubscriber topicSubscriber;

  /**
   * Destination to subscribe to
   */
  Topic topic;

  /**
   * Sets up all the JMS fixtures.
   *
   * Use close() when finished with object.
   *
   * @param factoryJNDI name of the topic connection factory to look up.
   * @param topicJNDI name of the topic destination to look up
   */
  public HelloSubscriber(String factoryJNDI, String topicJNDI)
    throws JMSException, NamingException
  {

    // Get the initial context
    Context context = new InitialContext();

    // Get the connection factory
    TopicConnectionFactory topicFactory =
      (TopicConnectionFactory)context.lookup(factoryJNDI);

    // Create the connection
    topicConnection = topicFactory.createTopicConnection();

    // Create the session
    topicSession = topicConnection.createTopicSession(
      // No transaction
      false,
      // Auto ack
      Session.AUTO_ACKNOWLEDGE);

    // Look up the destination
    topic = (Topic)context.lookup(topicJNDI);

    // Create a subscriber
    topicSubscriber = topicSession.createSubscriber(topic);

    // Set the message listener, which is this class since we implement
    // the MessageListener interface
    topicSubscriber.setMessageListener(this);

    System.out.println(
      "HelloSubscriber subscribed to topic: " + topicJNDI);

    // OBS! For the message listener to receive any messages the
    // connection has to be started
    topicConnection.start();
  }

  /**
   * Implementation of the MessageListener interface,
   * messages will be received through this method.
   */
  public void onMessage(Message m) {

    // Unpack the message, be careful when casting to the correct
    // message type. onMessage should not throw any application
    // exceptions.
    try {

      String msg = ((TextMessage)m).getText();
      System.out.println("HelloSubscriber got message: " + msg);

    } catch(JMSException ex) {

      System.err.println("Could not get text message: " + ex);
      ex.printStackTrace();

    }

  }

  /**
   * Close session and connection.
   */
  public void close() throws JMSException {

    topicSession.close();
    topicConnection.close();

  }

  /**
   * Run an example subscribing to topic testTopic.
   * Only works up to and including JBoss 2.4.0
   */
  public static void main(String[] args) {

    try {

      // Create the HelloSubscriber, giving it the name of the
      // TopicConnection Factory and the Topic destination to use in
      // lookup.
      HelloSubscriber subscriber = new HelloSubscriber(
        // Name of ConnectionFactory
        "TopicConnectionFactory",
        // Name of destination to publish to
        "topic/testTopic");

    } catch(Exception ex) {

      System.err.println(
        "An exception occurred while testing HelloSubscriber: " + ex);
      ex.printStackTrace();

    }

  }

} // HelloSubscriber

Figure 8.32. Running the HelloSubscriber example

ant jms-hello-subscriber

Figure 8.33. Output of running the HelloSubscriber example

jms-hello-subscriber:
     [echo] Using resources from: /home/pra/src/examples/resources
     [java] HelloSubscriber subscribed to topic: topic/testTopic

Figure 8.34. Running the HelloPublisher example

ant jms-hello-publisher

Figure 8.35. Output of running the HelloPublisher example

     [java] HelloSubscriber got message: Hello World no. 1
     [java] HelloSubscriber got message: Hello World no. 2
     [java] HelloSubscriber got message: Hello World no. 3
     [java] HelloSubscriber got message: Hello World no. 4
     [java] HelloSubscriber got message: Hello World no. 5
     [java] HelloSubscriber got message: Hello World no. 6
     [java] HelloSubscriber got message: Hello World no. 7
     [java] HelloSubscriber got message: Hello World no. 8
     [java] HelloSubscriber got message: Hello World no. 9
     [java] HelloSubscriber got message: Hello World no. 10

Figure 8.36. Shell script for HelloPublisher from org/jboss/docs/jms/bin/runHelloPublisher22.sh

#!/bin/bash

#
# Example script to run JMS client against JBoss 2.2.x
#

# Directory where jndi.properties is located
JNDI_RESOURCE_DIR=../resources/

# HelloPublisher class
CLIENT_CLASS_DIR=../../../../../build-examples/jms/classes/

# Required libs to run client
LIBS=$JBOSS_DIST/client/jbossmq-client.jar:\
$JBOSS_DIST/client/jnp-client.jar:\
$JBOSS_DIST/client/jta-spec1_0_1.jar:\
$JBOSS_DIST/lib/ext/jms.jar

# Agregated classpath
CLASSPATH=:$LIBS:\
$CLIENT_CLASS_DIR:\
$JNDI_RESOURCE_DIR

echo "Running with classpath $CLASSPATH"
$JAVA_HOME/bin/java -classpath $CLASSPATH org.jboss.docs.jms.client.HelloPublisher

Figure 8.37. Ant targets for JMS examples

ant jms-hello-publisher
ant jms-hello-subscriber
ant jms-hello-publisher25
ant jms-hello-subscriber25
ant jms-hello-sender
ant jms-hello-receiver
ant jms-hello-sender25
ant jms-hello-receiver25
ant jms-manual-jndi

Figure 8.38. Creating a topic programmatically in the same VM

// Get the MBean server
MBeanServer server = (MBeanServer)
  MBeanServerFactory.findMBeanServer(null).iterator().next();

// Invoke the MBean
server.invoke(new ObjectName("JMS", "service", "JMSServer"),
  "newTopic",
  new Object[] { "myTopic" },
  new String[] { "java.lang.String" });

Figure 8.39. [2.4.1] Creating a topic programmatically in the same VM

// Get the MBean server
MBeanServer server = (MBeanServer)
  MBeanServerFactory.findMBeanServer(null).iterator().next();

// Invoke the MBean
server.invoke(new ObjectName("JBossMQ", "service", "Server"),
  "createTopic",
  new Object[] { "myTopic" },
  new String[] { "java.lang.String" });

Figure 8.40. Creating a topic programmatically via a URL

//These are samples, not available in the example code.
String method = "newTopic";
String destName = "myCreated";

String action = "action=" + method + "?action=" + method +
  "&param0%2Bjava.lang.String=" + destName;

String arg = "/InvokeAction//JMS%3Aservice%3DJMSServer" + "/" + action;

URL url = new URL("http", "localhost", 8082, arg);

//Invoke the URL
HttpURLConnection con = (HttpURLConnection)url.openConnection();
con.connect();

Figure 8.41. [2.4.1] Creating a topic programmatically via a URL

//These are samples, not available in the example code.
String method = "createTopic";
String destName = "myCreated";

String action = "action=" + method + "?action=" + method +
  "&param0%2Bjava.lang.String=" + destName;

String arg = "/InvokeAction//JBossMQ%3Aservice%3DServer" + "/" + action;

URL url = new URL("http", "localhost", 8082, arg);

//Invoke the URL
HttpURLConnection con = (HttpURLConnection)url.openConnection();
con.connect();

Figure 8.42. Running the DestinationHelper example

ant jms-create-dest
ant jms-destroy-dest

Figure 8.43. [2.4.1] Running the DestinationHelper example

ant jms-create-dest25
ant jms-destroy-dest25