文档章节

ActiveMQ java Client

yunnet
 yunnet
发布于 2014/06/05 11:49
字数 95
阅读 2094
收藏 6
在网上找了一下,没找到相关的代码,给初学者做参考:

import java.text.SimpleDateFormat;
import java.util.Date;
import org.apache.activemq.transport.stomp.StompConnection;
import org.apache.activemq.transport.stomp.StompFrame;

class Listener {

    public static void main(String []args) throws Exception {
    	
    	final String topic = "/topic/TRACK";  
    	
    	StompConnection connection = new StompConnection();    	
    	connection.open("10.10.2.14", 61613);        
    	connection.connect("admin", "admin");    	
    	connection.subscribe(topic);     	
    	
    	while(true){  
            try {                 
                StompFrame message = connection.receive(60*1000);//60 秒钟timeout  
                System.out.println(new SimpleDateFormat("HH:mm:ss").format(new Date()) + " get -> " + message.getBody());  
            } catch (Exception e) {              	
                System.out.println(e.toString());  
                break;
            }                          
//            Thread.sleep(10);  
        }  
          
        connection.disconnect();  
    }  
    
}
    	
    	
    
    	     
    	
    	         
    


© 著作权归作者所有

共有 人打赏支持
yunnet
粉丝 7
博文 29
码字总数 23523
作品 2
广州
私信 提问
ActiveMQ学习记录 之 消息持久化

1:前言 这一段给公司开发消息总线有机会研究ActiveMQ,今天撰文给大家介绍一下他的持久化消息。本文只介绍三种方式,分别是持久化为文件,MYSql,Oracle。下面逐一介绍。 A:持久化为文件 这...

李格尔楞
2017/11/01
0
0
ActiveMQ安装配置和使用简例

本文作者:Zhang Phil 原文链接:http://blog.csdn.net/zhangphil/article/details/48173665 ActiveMQ安装配置和使用简例 ActiveMQ是一套JMS(Java Message Service)开源消息服务实现的组件...

开开心心过
2015/09/02
0
0
分布式--ActiveMQ 消息中间件(一)

1. ActiveMQ 1). ActiveMQ ActiveMQ是Apache所提供的一个开源的消息系统,完全采用Java来实现,因此,它能很好地支持J2EE提出的JMS(Java Message Service,即Java消息服务)规范。JMS是一组J...

凌浩雨
04/23
0
0
ActiveMQ:Communications link failure问题以及解决办法

ActiveMQ版本:5.5.1 MQ 所使用的 MySQL 是 InnoDB存储引擎 记录人:@郑昀现象: 业务表面现象:无。系统现象:无。 日志信息:业务系统发送 MQ 消息时,下面这种错误日志断断续续地一直都有...

旁观者-郑昀
2012/11/10
0
0
springJMS+activeMQ实践

运行环境:jdk1.6 ,javaEE5 , spring2.5 ,activeMQ5.4.3. 一定要注意activeMQ的版本与jdk的兼容性,最新的activeMQ版本估计要在jdk1.7以上才能运行。 先说一下activeMQ的安装: 1、下载:h...

wangrikui
2015/06/28
0
2

没有更多内容

加载失败,请刷新页面

加载更多

纹理与表面细节添加方法---凹凸映射

中国龙-扬科
7分钟前
0
0
20181115上课截图

小丑鱼00
14分钟前
0
0
初识css自定义属性

这算是一篇两篇文章译文的糅合体,旨在帮助理解css自定义属性。 今天,CSS预处理器是Web开发的标准。 预处理器的一个主要优点是它们使您能够使用变量, 这有助于您避免复制和粘贴代码,并简化...

嫣然丫丫丫
24分钟前
0
0
JAVA基础--session共享的前生今世

session共享的前生今世 Session及cookie基本概念及生命周期 session   当浏览器发起一个新的HTTP请求时,WEB服务端会主动创建一个session.并分配一个sessionID作为服务端识别客户端的一个标...

spinachgit
32分钟前
0
0
Deepin Linux 下把 UC 缓存视频变为 MP4 文件

本文是利用 FFMPEG 的功能实现的。 生成 file.txt文件 因为缓存文件都是数字,且文件夹内还有其他文件,包括 index.* 的文件。 $ ls -1v --hide=file.txt --hide=index* > file.txt 解释 ls...

不避风云
33分钟前
0
2

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部