/**
* 基于stomp协议接收JMS消息
* @param args 参数
*/
@SuppressWarnings("unchecked")
public static void main(String[] args) throws Exception
{
StompConnection conn = new StompConnection();
conn.open("127.0.0.1", 61613);
conn.connect("user1", "password1");
HashMap<String, String> headers = new HashMap<String,String>();
headers.put(Stomp.Headers.TRANSFORMATION, "jms-stomp-map-json");
conn.subscribe(JMSInfo.STOMP_QUEUE_NAME, Subscribe.AckModeValues.AUTO, headers);
// conn.subscribe(JMSInfo.STOMP_TOPIC_NAME, Subscribe.AckModeValues.AUTO, headers);
while (true) {
try {
StompFrame msg = conn.receive(60000);
String dataType = msg.getHeaders().get("dataType");
String className = msg.getHeaders().get("className");
String text = msg.getBody();
if ("json".equals(dataType) && "java.util.Map".equals(className)) {
Map<String, Object> map = JsonUtils.toJavaObject(text, Map.class);
System.out.println("received map: " + map);
} else {
System.out.println("received text: " + text);
}
// 暂停 0.5 秒
Thread.sleep(500);
} catch (Exception e) {
e.printStackTrace();
break;
}
}
conn.unsubscribe(JMSInfo.STOMP_QUEUE_NAME);
// conn.unsubscribe(JMSInfo.STOMP_TOPIC_NAME);
conn.disconnect();
}
分享到:
相关推荐
标签:activemq-stomp-5.10.0-sources.jar,activemq,stomp,5.10.0,sources,jar包下载,依赖包
标签:activemq-stomp-5.10.0.jar,activemq,stomp,5.10.0,jar包下载,依赖包
标签:activemq-stomp-5.9.1.jar,activemq,stomp,5.9.1,jar包下载,依赖包
标签:activemq-stomp-5.8.0.jar,activemq,stomp,5.8.0,jar包下载,依赖包
标签:activemq-stomp-5.9.0.jar,activemq,stomp,5.9.0,jar包下载,依赖包
标签:activemq-stomp-5.9.0-sources.jar,activemq,stomp,5.9.0,sources,jar包下载,依赖包
标签:activemq-stomp-5.8.0-sources.jar,activemq,stomp,5.8.0,sources,jar包下载,依赖包
标签:activemq-stomp-5.9.0-javadoc.jar,activemq,stomp,5.9.0,javadoc,jar包下载,依赖包
标签:activemq-stomp-5.9.1-sources.jar,activemq,stomp,5.9.1,sources,jar包下载,依赖包
标签:activemq-stomp-5.8.0-javadoc.jar,activemq,stomp,5.8.0,javadoc,jar包下载,依赖包
标签:activemq-stomp-5.10.0-javadoc.jar,activemq,stomp,5.10.0,javadoc,jar包下载,依赖包
标签:activemq-stomp-5.9.1-javadoc.jar,activemq,stomp,5.9.1,javadoc,jar包下载,依赖包
activemq-all-5.8.0.jar 下载 activemq-all-5.8.0.jar 下载 activemq-all-5.8.0.jar 下载 activemq-all-5.8.0.jar 下载 activemq-all-5.8.0.jar 下载
activemq-pool-5.8.0-sources.jar
apache-activemq-5.16.0.zip
赠送jar包:activemq-core-5.7.0.jar; 赠送原API文档:activemq-core-5.7.0-javadoc.jar; 赠送源代码:activemq-core-5.7.0-sources.jar; 包含翻译后的API文档:activemq-core-5.7.0-javadoc-API文档-中文...
赠送jar包:activemq-protobuf-1.1.jar; 赠送原API文档:activemq-protobuf-1.1-javadoc.jar; 赠送源代码:activemq-protobuf-1.1-sources.jar; 包含翻译后的API文档:activemq-protobuf-1.1-javadoc-API文档-...
apache-activemq-5.9.0-bin.zip
apache-activemq-5.8.0-bin.zip
本代码关于activemq-cpp的核心代码参考的chenxun2009的博客园,其他部分包括:从配置文件中读取消息通道,过滤条件等信息。