文档章节

ActiveMQ java Client

yunnet
 yunnet
发布于 2014/06/05 11:49
字数 95
阅读 2102
收藏 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
粉丝 10
博文 29
码字总数 23537
作品 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
ubuntu上安装activemq,然后启动不起来,配置文件要改什么地方吗?

我在ubuntu上sudo apt-get intstall activemq 后, 然后到bin下启动activemq:./activemq start INFO: Loading '/usr/share/activemq/activemq-options' INFO: Using java '/usr/bin/java' ......

海空天阔007
2015/12/23
1K
1
分布式--ActiveMQ 消息中间件(一)

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

凌浩雨
2018/04/23
0
0
用java代码如何设置activemq消息持久化到数据库中?

想将activeMQ消息持久化到数据库中,网上都是说将activeMQ.xml文件做如下设置: 我能否在java代码中进行设置呢?因为我是在eclipse中导入的activemq-all-5.2.0.jar包,开发的系统,包中没有a...

吕奕
2010/03/20
2.4K
0

没有更多内容

加载失败,请刷新页面

加载更多

如何在 Linux 系统查询机器最近重启时间

在你的 Linux 或类 UNIX 系统中,你是如何查询系统上次重新启动的日期和时间?怎样显示系统关机的日期和时间? last 命令不仅可以按照时间从近到远的顺序列出该会话的特定用户、终端和主机名...

来来来来来
今天
1
0
Redis协议是什么样的

前言 我们用过很多redis的客户端,有没有相过自己撸一个redis客户端? 其实很简单,基于socket,监听6379端口,解析数据就可以了。 redis协议 解析数据的过程主要依赖于redis的协议了。 我们...

春哥大魔王的博客
今天
3
0
乱入Linux界的我是如何学习的

欢迎来到建哥学Linux,咳!咳!咳!开个玩笑哈,我是一个IT男,IT界的入门选手,正在学习Linux。 在之前,一直想进军IT界,学习IT技术,但是苦于没有人指导,也不知道学什么,最开始我自己在...

linuxCool
今天
3
0
携程Apollo统一配置中心的搭建和使用(java)

一.Apollo配置中心介绍 1、What is Apollo 1.1 Apollo简介 Apollo(阿波罗)是携程框架部门研发的开源配置管理中心,能够集中化管理应用不同环境、不同集群的配置,配置修改后能够实时推送到...

morpheusWB
今天
2
0
远程获得的有趣的linux命令

使用这些工具从远程了解天气、阅读资料等。 我们即将结束为期 24 天的 Linux 命令行玩具日历。希望你有一直在看,如果没有,请回到开始,从头看过来。你会发现 Linux 终端有很多游戏、消遣和...

Linux就该这么学
今天
6
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部