`
maishj
  • 浏览: 84034 次
  • 性别: Icon_minigender_1
  • 来自: 广州
社区版块
存档分类
最新评论

关于ActiveMQ持久订阅

 
阅读更多
仓促总结下。
//clientID必须唯一
conn.setClientID(clientID);
//参数1:发送主题目的地,参数2:持久订阅者名字,参数3:消息过滤条件,参数4:是否只接收同一clientID的信息,默认false
MessageConsumer consumer=session.createDurableSubscriber((Topic) destination,subName,"selector = apple",noLocal);


分享到:
评论
1 楼 kimmking 2012-07-13  
noLocal 是只能接收同一个connectionId的消息,而不是clientId
内部实现是添加了一个比较connectionId的selector

相关推荐

    spring+activemq topic持久化订阅

    spring +activemq topic消息持久化订阅实例,整个项目中有activemq和spring的整合的所有实例,topic的持久化配置是在ApplicationContext3C、ApplicationContext3C2以及ApplicationContext3P三个中,消息生产者:...

    如何实现ActiveMq的Topic的持久订阅

    NULL 博文链接:https://768992698.iteye.com/blog/2343328

    ActiveMQ订阅模式持久化实现

    一个订阅通道,支持多个客户端监听,当某个客户端掉线后,再上线的时候可以收到它没有接收到的消息。

    ActiveMQ持久订阅设置面试中经常问道的问题一.txt

    程序员面试题

    activemq消息持久化所需Jar包

    activemq消息持久化所需Jar包,详情请参见博文:http://blog.csdn.net/l1028386804/article/details/68997105

    spring集成activemq演示queue和topic 持久化

    本人在学习activemq,然后 测试完成的demo, 包含了queue,topic,持久化到mysql,订阅模式,包好用

    ActiveMQ消息服务配置

    ActiveMQ配置说明,包括java内存调整,主从集群配置,自动清理离线客户端(避免长时间持久订阅占用内存)等

    activemq-demo

    集成activemq和spring 的消息推送 包含普通队列消息和持久化订阅消息

    ActiveMQ——Java连接ActiveMQ

    topic不保存消息它是无状态的不落地,假如无人订阅就去生产,那就是一条废消息,所以,一般先启动消费者再启动生产者JMS规范允许客户创建持久订阅,这在一定程度上放松了时间上的相关性要求。持久订阅允许消费者消费...

    boot-example-activemq-topic-2.0.5

    SpringBoot+ActiveMQ-发布订阅 Topic 主题 * 消息消费者(订阅方式)消费该消息 * 消费生产者将发布到topic中,同时有多个消息消费者(订阅)消费该消息 * 这种方式和点对点方式不同,发布到topic的消息会被所有...

    ActiveMQ.chm

    activeMQ集成流程: activceMQ从了解过程,安装,消息发送模式的讲解,从点对点模式到订阅模式,及深入了解JMS,再到集成到spring,.消息的持久化,高级特性,应用场景,面试常用问题

    消息队列中间件ActiveMQ入门到精通视频教程及资料

    003-顺序消费+消息过滤SELECTOR+MessageConsumer+MySql持久化;004-p2p模式+pulish-subscribe发布订阅模式+与spring集成;005-集群部署1;006-集群部署2;007-集群部署3;activemq集群配置文档.pdf;ActiveMQ(中文)...

    activeMQ5.2的jar包及使用实例

    activeMQ5.2的jar包及使用实例,它既支持点到点(point-to-point)(PTP)模型和发布/订阅(Pub/Sub)模型。支持同步与异步消息发送。JDBC持久性管理使用数据库表来存储消息 。

    ActiveMQ中文手册

    1.2.6 持久订阅 3 1.2.7 本地事务 3 1.3 JMS 规范的变迁 4 2.ActiveMQ 4 2.1 Broker 4 2.1.1 运行Broker 4 2.1.2 嵌入式Broker 4 2.1.3 监控Broker 5 2.2 Transport 9 2.2.1 VM Transport 9 2.2.2...

    ActiveMQ是Apache软件基金会所研发开源的消息中间件,为应用程序提供高效的、可扩展的、稳定的和安全的企业级消息通信

    抛开网络服务(Network Services)不说,我们应该知道的是ActiveMQ的三个重要组成部分:连接(Connectors)、消息模式(Topic,Queue)、消息持久化方式。 连接(Connectors)  ActiveMQ提供了多种应用协议,如...

    java实现的消息中间件之AcitveMQ详解,学习学习

    activemq_acks:存储持久订阅的信息和最后一个持久订阅接收的消息ID activemq_lock:跟kahadb的lock文件类似,确保数据库在某一时刻只有一个broker在访问 Memory 消息存储 他是基于内存的消息存储,就是消息存储在...

    ActiveMQ从入门到精通(二)

    本文来自于jianshu,介绍了消息的顺序消费、JMSSelectors、消息的同步/异步接受方式、Message、P2P/PubSub、持久化订阅、持久化消息到MySQL以及与Spring整合等知识。接上一篇,本篇主要讨论的话题是:消息的顺序消费...

    ActiveMq由浅入深讲解+面试题50道讲解

    本课程共分36节,内容包括MQ概述和工作流程,启动过程与启动异常分析,消息的基本模型,基于队列的生产者和消费者,基于发布-订阅的生产者和消费者,消息的同步消费和异步消费,消息的数据类型,身份认证,持久化...

Global site tag (gtag.js) - Google Analytics