鍍金池/ 問答/Java  HTML/ rabbitmq x-delayed-message 如何設(shè)置多次延時(shí)回調(diào)

rabbitmq x-delayed-message 如何設(shè)置多次延時(shí)回調(diào)

聲明exchange類型為x-delayed-message,
聲明queue的參數(shù)中增加x-dead-letter-exchange,
消息頭部增加x-delay參數(shù),
在消費(fèi)時(shí),回執(zhí)negative ack
這種方式來實(shí)現(xiàn)延時(shí)隊(duì)列。這種方式只能給消息添加固定的延時(shí)時(shí)間。
如果要實(shí)現(xiàn)第一次10秒,第二次30秒,第三次60秒,這種多次不同時(shí)長的延時(shí)消息?是否能在延時(shí)類型的exchange中動(dòng)態(tài)的修改x-delay的時(shí)長?還是只能通過在消費(fèi)時(shí)重新包裝消息,修改x-delay參數(shù),再發(fā)布到延時(shí)類型的exchange中?

回答
編輯回答
喵小咪

目前采用的方式是對(duì)消息重新包裝,修改xdelay參數(shù),重新發(fā)布到延時(shí)exchange中實(shí)現(xiàn)的

2018年1月29日 20:35