没有合适的资源？快使用搜索试试~ 我知道了~

文库首页安全技术网络安全7、message 时间1

7、message 时间1

需积分: 0 0 下载量 186 浏览量 2022-08-08 22:57:14 上传评论收藏 878KB DOCX 举报

温馨提示

试读

12页

2、message 时间1、xml开启时间属性 <broker xmlns="http://activemq.apache.org/schema/core" b

资源详情

资源评论

资源推荐

1、advisory，顾问，消费者获取生产者的信

息

1、下面配置 advisoryForConsumed 为 true 代表访问 topic

的时候，advisory 的功能是打开的，默认是 false

<policyEntry topic=">" advisoryForConsumed ="true">

2、创建生产者和消费者，这里使用的是之前的代码非持久

化的 topic，进行的测试，先运行消费者，后运行生产者。

advisory-MyTopic 为 destinection

3、浏览器中观察，会发现多出来很多系统的 topic

4、现在我们来获取下系统的 topic 的一些信息，消费者中

获取这个 topic 的信息，下面获取 message 的时候直接用

TestMessage 会报异常，说是消息转化失败。所以不能用

TestMessage 来获取消息，下面是获取生产者的信息

Destination destination =

session.createTopic("ActiveMQ.Advisory.Producer.Topic.advisory_MyTopic");

MessageConsumer consumer = session.createConsumer(destination);

System.out.println("创建 advisory_MyTopic 消费者");

Message message = consumer.receive();

while(message!=null) {

if(message instanceof ActiveMQMessage){

ActiveMQMessage amsg = (ActiveMQMessage)message;

ProducerInfo prod = (ProducerInfo) amsg.getDataStructure();

System.out.println(amsg.getProperty("producerCount"));

System.out.println(prod.getProducerId());

}

message = consumer.receive();

}

5、控制台打印信息

剩余11页未读，继续阅读

内容反馈

洋葱庄

粉丝: 19
资源: 311

上传资源快速赚钱

我的内容管理展开

我的资源快来上传第一个资源

我的收益

登录查看自己的收益

我的积分登录查看自己的积分

我的C币登录后查看C币余额

我的收藏

我的下载

下载帮助

前往需求广场，查看用户热搜

7、message 时间1

评论0

最新资源

7、message 时间1

评论0

message

message:c8d6df80dc60a8e5f0dbda94a987f6ab5687b1cc

lion-message

HL7 Message 编辑工具

http-message:严格，快速地实施PSR-7和PSR-17

小程序源码 HandlerMessage1.zip

bootstrap-banner-message:标语消息库，用于在指定时间段内显示站点范围内可拒绝的消息

flash-message

leave_message

message-broker

greeting-message

message_app

淘宝专用浏览器V2.6.3.9

小程序源码 HandlerMessage2.zip

小程序源码 HandlerMessage3.zip

价值7万元的大型全功能中文电子邮局系统

构建高并发高可用的电商平台架构

message-board

message.zip

plant-message

message-client

log message

小程序 Message-Driven Bean EJB实例源代码（源码）.rar

Android 面试宝典

RFC3315(中文) 动态主机配置协议-DHCPv6

websocket-1.0-SNAPSHOT.jar

网络基本端口对应关系

最新资源