Skip to content

HeyFL/mq-mover

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

13 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

mq-mover

通用【队列消息】转移【另外一个队列】 可用作死信手动重新消费

支持动态修改MQ用户名、密码、VH等信息

step1:配置src/main/resources/application.properties

#MQ Setting
spring.rabbitmq.default.addresses=127.0.0.1:5672
spring.rabbitmq.default.username=MQ_userName
spring.rabbitmq.default.password=MQ_password
spring.rabbitmq.default.publisher-confirms=true
spring.rabbitmq.PFS_PDS.virtual-host=MQ_virtual-host

请求JSON报文:

{
	"queue": "PFS_PICKUP_Q_PREDICT_DEAD",//原队列
	"toExchange": "PFS_PICKUP_X_PREDICT",//目的地队列Exchange
	"toRoutingKey": "PFS_PICKUP_R_PREDICT",//目的地队地RoutingKey
	"moveNum": 10 //转移多少条消息
}

本人使用场景:

场景描述:【队列A】消费者系统因为BUG、故障,导致MQ消息消费失败,丢到【死信队列B】;
系统恢复后,需要重新消费死信消息;这时候需要人工一条条把消息搞回原来的队列;

本程序解决这个问题

About

【推荐使用】动态通用【队列消息】手动转移【另外一个队列】

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages