Page Comparison

...

Table of Contents

maxLevel	3

Prerequisites

Download the hornetq-all-new.jar and copy it to the <EI_HOME>/lib/ directory.
Replace the geronimo-jms_1.1_spec-1.1.0.wso2v1.jar file in the <EI_HOME>/wso2/lib/endorsed/ directory with javax.jms-api-2.0.1.jar
Download HornetQ from http://hornetq.jboss.org/downloads and extract the tar.gz.

Configuring and starting the HornetQ message broker

Open the <HornetQ_HOME>/config/stand-alone/non-clustered/hornetq-jms.xml file in a text editor and add the following configuration:

Code Block

language	xml

<connection-factory name="QueueConnectionFactory">
      <xa>false</xa>
      <connectors>
         <connector-ref connector-name="netty"/>
      </connectors>
      <entries>
         <entry name="/QueueConnectionFactory"/>
      </entries>
</connection-factory>
 
<connection-factory name="TopicConnectionFactory">
      <xa>false</xa>
      <connectors>
         <connector-ref connector-name="netty"/>
      </connectors>
      <entries>
         <entry name="/TopicConnectionFactory"/>
      </entries>
</connection-factory>

<queue name="wso2">
      <entry name="/queue/mySampleQueue"/>
</queue>

<topic name="sampleTopic">
      <entry name="/topic/exampleTopic"/>
</topic>

Start the HornetQ message broker
- To start the message broker on Linux, navigate to the <HornetQ_HOME>/bin/ directory and execute the run.sh command with root privileges.

Building the sample scenario

The XML configuration for this sample scenario is as follows:

...

Start WSO2 EI with the sample configuration.

Executing the sample scenario

Run the following java file to publish a message to the JMS queue:

Code Block

language	java
title	SOAPPublisher.java

package JMSXDeliveryCount;

import java.util.Properties;
import java.util.logging.Logger;

import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSContext;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class SOAPPublisher {
	private static final Logger log = Logger.getLogger(SOAPPublisher.class.getName());

	// Set up all the default values
	private static final String param = "IBM";

	// with header for inbounds
	private static final String MESSAGE_WITH_HEADER =
			"<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\">\n" +
					"   <soapenv:Header/>\n" +
					"<soapenv:Body>\n" +
					"<m:placeOrder xmlns:m=\"http://services.samples\">\n" +
					"    <m:order>\n" +
					"        <m:price>" +
					getRandom(100, 0.9, true) +
					"</m:price>\n" +
					"        <m:quantity>" +
					(int) getRandom(10000, 1.0, true) +
					"</m:quantity>\n" +
					"        <m:symbol>" +
					param +
					"</m:symbol>\n" +
					"    </m:order>\n" +
					"</m:placeOrder>" +
					"   </soapenv:Body>\n" +
					"</soapenv:Envelope>";
	private static final String DEFAULT_CONNECTION_FACTORY = "QueueConnectionFactory";
	private static final String DEFAULT_DESTINATION = "queue/mySampleQueue";
	private static final String INITIAL_CONTEXT_FACTORY = "org.jnp.interfaces.NamingContextFactory";
	private static final String PROVIDER_URL = "jnp://localhost:1099";

	public static void main(String[] args) {

		Context namingContext = null;

		try {

			// Set up the namingContext for the JNDI lookup
			final Properties env = new Properties();
			env.put(Context.INITIAL_CONTEXT_FACTORY, INITIAL_CONTEXT_FACTORY);
			env.put(Context.PROVIDER_URL, System.getProperty(Context.PROVIDER_URL, PROVIDER_URL));
			namingContext = new InitialContext(env);

			// Perform the JNDI lookups
			String connectionFactoryString =
					System.getProperty("connection.factory",
					                   DEFAULT_CONNECTION_FACTORY);
			log.info("Attempting to acquire connection factory \"" + connectionFactoryString + "\"");
			ConnectionFactory connectionFactory =
					(ConnectionFactory) namingContext.lookup(connectionFactoryString);
			log.info("Found connection factory \"" + connectionFactoryString + "\" in JNDI");

			String destinationString = System.getProperty("destination", DEFAULT_DESTINATION);
			log.info("Attempting to acquire destination \"" + destinationString + "\"");
			Destination destination = (Destination) namingContext.lookup(destinationString);
			log.info("Found destination \"" + destinationString + "\" in JNDI");

			// String content = System.getProperty("message.content",
			// DEFAULT_MESSAGE);
			String content = System.getProperty("message.content", MESSAGE_WITH_HEADER);

			try (JMSContext context = connectionFactory.createContext()) {
				log.info("Sending  message");
				// Send the message
				context.createProducer().send(destination, content);
			}

		} catch (NamingException e) {
			log.severe(e.getMessage());
		} finally {
			if (namingContext != null) {
				try {
					namingContext.close();
				} catch (NamingException e) {
					log.severe(e.getMessage());
				}
			}
		}
	}


	private static double getRandom(double base, double varience, boolean onlypositive) {
		double rand = Math.random();
		return (base + (rand > 0.5 ? 1 : -1) * varience * base * rand) *
				(onlypositive ? 1 : rand > 0.5 ? 1 : -1);
	}
}

Analyzing the output

When you analyze the output on the WSO2 EI console, you will see an entry similar to the following:

...

Versions Compared

Old Version 1

New Version 2

Key

Prerequisites

Configuring and starting the HornetQ message broker

Building the sample scenario

Executing the sample scenario

Analyzing the output