Using StompConnect with HornetQ
Run The Example#
For simplicity, all the jars are included with the examples in the
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
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:
We send a message to the destination
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 ^@