java rabbitmq topic_java rabbitmq 发送消息是topic模式, 消费者 怎么消费多个不同名字的队列?...
这里有几个不同的队列 名字没有什么规则 就是xxx.xxx exchange也是和队列的名字一样的
package com.monitor.receiver.queue;
import java.util.List;
import java.util.Map;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.retry.annotation.Recover;
import org.springframework.stereotype.Component;
import com.monitor.receiver.jpush.PushUtil;
import com.monitor.receiver.pojo.SysWarnInfo;
import com.monitor.receiver.service.SysWarnInfoService;
@Recover
@Component
public class Receive {
@Autowired
SysWarnInfoService sysWarnInfoService;
@RabbitListener(queues="Adine.One")
public void process_sys_warn1(Map msg) {
if(msg!=null){
List< SysWarnInfo>list=sysWarnInfoService.findAccountList(msg);
PushUtil.jiguangPush(list);
}
}
@RabbitListener(queues="lous.wqui")
public void process_sys_warn2(Map msg) {
if(msg!=null){
List< SysWarnInfo>list=sysWarnInfoService.findAccountList(msg);
PushUtil.jiguangPush(list);
}
}
}
向上面的消费者 写了两个监听,根据队列名 监听指定的队列。 但是现在队列是动态生成的 根本不知道有多少个队列,也不知道队列名字 反正队列名生成规则就是XXX.XXX(用户名.xxx类型)。 能不能只写一个消费去消费此mq服务器所有的队列? 像那种#.# 怎么配置的 就是消费所有的意思 怎么消费所有?
java rabbitmq topic_java rabbitmq 发送消息是topic模式, 消费者 怎么消费多个不同名字的队列?...相关推荐
- rabbitmq 学习-9- RpcClient发送消息和同步接收消息原理
rabbitmq 学习-9- RpcClient发送消息和同步接收消息原理
- 在Rabbitmq管理台发送消息
有的时候我们因为一些特殊的原因或者需要测试某个功能,需要发送mq,但是又不能直接触发消息.这种情况下,我们可以直接在mq控制台发送消息. 一.首先打开rabbitmq管理台 二.右上角选择环境,开发或 ...
- java访问微信接口发送消息
最近在开发activiti流程的时候有个需求:流程到达每个审批节点后,需要向该节点的审批人发送一个消息,提示有审批需要处理. 参考了一下微信的开发者文档和网络上的一些技术博客,现在记录一下.以便后续继 ...
- java 调用微信api发送消息
要在 Java 中调用微信 API 发送消息,你需要做的第一步是在微信公众平台中注册自己的公众号,然后获取到自己的 AppID 和 AppSecret. 然后你可以使用微信公众平台提供的开发文档,来了 ...
- java微信小程序发送消息
首先参考文档:https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/subscribe-message/subsc ...
- Java微信公众号发送消息-保姆级教程附源码
目录 1. 概念说明: 2. 开发准备: 3. 测试demo(更改配置信息即可使用) 3.1. 服务器配置 3.1.1.配置填写说明 3.1.2.校验服务器有效性: 3.1.3.URL后端接口代码和校 ...
- java对接钉钉发送消息通知
现在,许多的消息会议,工作任务安排都不在是通过邮件呀,或者是使用口头表达的形式了,都是一些通讯软件进行分发,在工作中,也会有一些东西需要通过程序进行自动发送一些消息通知到指定的人,告诉他,你的,干活的 ...
- RabbitMQ实现生产者发送消息异步confirm
一.生产者 /*** 异步确认生产者** @author : konsy* @date : 2022-04-12 17:04**/ public class ConfirmMessageProvide ...
- rabbitmq管理页面发送消息
Delivery mode: 是否持久化,1 - Non-persistent,2 - Persistent Headers:Headers can have any name. Only long ...
最新文章
- 实现HTTP协议Get、Post和文件上传功能——使用libcurl接口实现
- JQuery(选择器)
- php redis并发读写,PHP使用Redis实现防止大并发下二次写入的方法
- 非常详细的Django使用Token(转)
- std中稳定排序算法_源代码库已开放 | 哈工大硕士生用 Python 实现了 11 种经典数据降维算法...
- Cisco 4507R+E四引擎VSS故障解决
- Ackermann函数的递归求值
- Facebook正在追踪你,哪怕你不是用户丨扎克伯格国会听证第二日
- docker教程_2 docker常见命令
- VSTO 3.0 for Office 2007 Programming
- Redis 集群中的纪元(epoch)
- 编程基本功:典型的柳氏风格命名一例
- rs232转usb驱动_Trinamic发布6轴步进电机驱动模块TMCM-6214
- oracle lgt,第 2 章 Fortran 95 内函数
- 电子书格式问题的本质
- 怎么读取二代身份证UUID----在STM32+CLRC663平台试验成功
- 计算机键盘图 指法,键盘指法练习图
- php将ppt转jpg图片的具体步骤代码
- 2018年中国 Micro-LED 行业市场前景研究报告(简版)
- Servlet中ServletConfig接口和ServletContext接口的作用
热门文章
- 初识python教案青岛版八年级_青岛版信息技术六上第二单元第8课8.初识python教案...
- python如何测试仪器_如何测试pytest设备本身?
- 提示错误“'=' not supported between instances of 'range' and 'int'”
- python —skleran分类示例(全流程)
- opencv进阶学习9:图像阈值大全,图像二值化,超大图像二值化
- Spring IoC(一)IoC容器的设计与实现:BeanFactory与ApplicationContext
- Java9中的GC 调优
- BOOST_VMD_ASSERT_IS_TUPLE宏相关的测试程序
- boost::mpl模块实现pair_view相关的测试程序
- boost::math模块具有输出和输入方面的非有限环回的简要基本测试