mirror of https://github.com/apache/activemq.git
fixing Stomp example
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@932283 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
2895197d0d
commit
b6eef83ef4
|
@ -33,10 +33,6 @@ public class StompExample {
|
|||
connection.open("localhost", 61613);
|
||||
|
||||
connection.connect("system", "manager");
|
||||
StompFrame connect = connection.receive();
|
||||
if (!connect.getAction().equals(Stomp.Responses.CONNECTED)) {
|
||||
throw new Exception ("Not connected");
|
||||
}
|
||||
|
||||
connection.begin("tx1");
|
||||
connection.send("/queue/test", "message1");
|
||||
|
|
Loading…
Reference in New Issue