Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
HornetQ Server with Stomp Connect
Java
branch: master
Failed to load latest commit information.
lib
src/org/hornetq/stomp
.classpath
.gitignore
.project
README.md
build.xml

README.md

Using StompConnect with HornetQ

This example shows how to setup a HornetQ server with Stomp (in less than 30 lines of code) so that Stomp clients can connect to it.

Run The Example

Prerequisites

For simplicity, all the jars are included with the examples in the lib/ directory. You can use Apache Ant to run the server.

Start the server

 $ ant server
 ...

 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

Stomp Client

We 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:

 CONNECT
 login:
 passcode:

 ^@

(^@ is Ctl-@)

The server replies that we are connected:

 CONNECTED
 session:null

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

 SEND 
 destination:/queue/a

 hello, hornetq!
 ^@

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

We open a new Stomp client and connect to the server:

 $ telnet localhost 61613

 CONNECT
 login:
 passcode:

 ^@

And we subscribe to the destination:

 SUBSCRIBE
 destination: /queue/a
 ack:client

 ^@

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

 MESSAGE
 message-id:ID:7b28be24-00f1-11df-b27f-001c42000009:0000000000000000
 destination:/queue/a
 timestamp:1263462299779
 JMSXDeliveryCount:1
 expires:0
 subscription:/subscription-to//queue/a
 priority:4

 hello, hornetq!

Finally, we acknowledge the message:

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

 ^@
Something went wrong with that request. Please try again.