Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

merge #159 - Improve jms/Stomp example

This commit is contained in:
Andy Taylor 2015-03-09 09:25:27 +00:00
parent 10bb4568c3 fdff838d78
commit 1a8951a564
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
examples/jms/stomp/src/main/java/org/apache/activemq/jms/example/StompExample.java
View File

@ -16,6 +16,7 @@
*/ */
package org.apache.activemq.jms.example; package org.apache.activemq.jms.example;
import java.io.InputStream;
import java.io.OutputStream; import java.io.OutputStream;
import java.net.Socket; import java.net.Socket;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
@ -28,6 +29,7 @@ import javax.jms.Session;
import javax.jms.TextMessage; import javax.jms.TextMessage;
import javax.naming.InitialContext; import javax.naming.InitialContext;
import org.apache.activemq.common.example.ActiveMQExample; import org.apache.activemq.common.example.ActiveMQExample;
/** /**
@ -65,6 +67,8 @@ public class StompExample extends ActiveMQExample
END_OF_FRAME; END_OF_FRAME;
sendFrame(socket, connectFrame); sendFrame(socket, connectFrame);
readFrame(socket);
// Step 3. Send a SEND frame (a Stomp message) to the // Step 3. Send a SEND frame (a Stomp message) to the
// jms.queue.exampleQueue address with a text body // jms.queue.exampleQueue address with a text body
String text = "Hello, world from Stomp!"; String text = "Hello, world from Stomp!";
@ -133,4 +137,16 @@ public class StompExample extends ActiveMQExample
outputStream.flush(); outputStream.flush();
} }
private static String readFrame(Socket socket) throws Exception
{
byte[] bytes = new byte[2048];
InputStream inputStream = socket.getInputStream();
int nbytes = inputStream.read(bytes);
byte[] data = new byte[nbytes];
System.arraycopy(bytes, 0, data, 0, data.length);
String resp = new String(data, "UTF-8");
System.out.println("Got response from server: " + resp);
return resp;
}
} }