Jeff Mesnil
Weblog · Dev · Photos · Books

Using Stomp with HornetQ

January 14, 2010

My daily job at Red Hat is to work on HornetQ.

As the home page says:

HornetQ is an open source project to build a multi-protocol, embeddable, very high performance, clustered, asynchronous messaging system

Yesterday, we released HornetQ 2.0.0 which supports 2 messaging APIs, JMS and HornetQ's own Core messaging API.
However, we already have users who wants to use HornetQ in non-Java environments.

One solution is to use Stomp with HornetQ so that any Stomp clients can communicate with HornetQ.

To show how to setup HornetQ and Stomp together, I created a project with the source code and all the required jars on GitHub:

git clone git://

The source code consists in a single class which configures and starts a fully functional standalone HornetQ server and connects it to Stomp:

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

      Configuration configuration = new ConfigurationImpl();
      // to keep things simple, we disable security. In real use, we'd setup authentication properly
      // we add a In-VM acceptor to HornetQ as the server will be accessible outside using Stomp
         new TransportConfiguration(InVMAcceptorFactory.class.getName()));
      // we add a Queue which will be available to Stomp under /queue/a
         new QueueConfiguration("jms.queue.a", "jms.queue.a",null, true));

      // we create the HornetQ server using this config
      HornetQServer hornetqServer = HornetQServers.newHornetQServer(configuration);
      // we also create a JMS server manager as Stomp is using the JMS API
      JMSServerManager jmsServer = new JMSServerManagerImpl(hornetqServer);
      // starting the JMS server will also start theHornetQ server underneath

      // We create directly a JMS ConnectionFactory which will be 
      // connected to the HornetQ server using In-VM connection
      ConnectionFactory connectionFactory = HornetQJMSClient.createConnectionFactory(
         new TransportConfiguration(InVMConnectorFactory.class.getName()));

      // We inject the connection factory in Stomp
      StompConnect stompConnect = new StompConnect(connectionFactory);
      // and start it using default Stomp config

As both HornetQ server and clients are in the same Virtual Machine, we use in-vm connections. There will be only one port opened: the port used by Stomp (61613 by default)

To run the server, use Apache Ant:

$ ant server


   [java] 14 janv. 2010 10:57:30 org.hornetq.core.logging.impl.JULLogDelegate info
   [java] INFO: live server is starting..
   [java] 14 janv. 2010 10:57:30 org.hornetq.core.logging.impl.JULLogDelegate warn
   [java] ATTENTION: Security risk! It has been detected that the cluster admin user and password have not been changed from the installation default. Please see the HornetQ user guide, cluster chapter, for instructions on how to do this.
   [java] 14 janv. 2010 10:57:30 org.hornetq.core.logging.impl.JULLogDelegate info
   [java] INFO: HornetQ Server version 2.0.0.GA (Hornet Queen, 113) started
   [java] 14 janv. 2010 10:57:30 org.codehaus.stomp.tcp.TcpTransportServer doStart
   [java] INFO: Listening for connections at: tcp://BlackBook.local:61613

That's all you need to have a fully functional messaging server accessible to any Stomp clients.

To check that it works properly, we will use telnet as our Stomp client:

$ telnet localhost 61613

First, we connect to the server.
To keep things simple, we have disabled security from the server so that we can connect to it anonymously:



(^@ is Ctl-@)

The server replies that we are connected:


We send a message to the destination /queue/a:


hello, hornetq!

To make things more interesting, you can now kill the server and restart it. The message that was sent to the queue is persisted and will be consumed after the server is restarted.

Once the server is restarted, we open a new Stomp client and connect to the server:

$ telnet localhost 61613



And we subscribe to the destination:

destination: /queue/a


As soon as we are subscribed, we will receive the message that was sent to the destination:


hello, hornetq!

Finally, we acknowledge the message:

message-id: ID:7b28be24-00f1-11df-b27f-001c42000009:0000000000000000


By leveraging HornetQ & Stomp, you can use messaging queues in your applications regardless on the platform you use.

One key decision of HornetQ was to make it simple to embed and integrate with other projects. This simple example shows that we reach our goal with Stomp.