When I used the delay plug-in, I started the corresponding message confirmation and found that the message replied to the ACK message to the switch, but the switch made an error to the corresponding queue,Tips:replyText:NO_ROUTE #175
Replies: 2 comments 3 replies
-
I will convert this issue to a GitHub discussion. Currently GitHub will automatically close and lock the issue even though your question will be transferred and responded to elsewhere. This is to let you know that we do not intend to ignore this but this is how the current GitHub conversion mechanism makes it seem for the users :( |
Beta Was this translation helpful? Give feedback.
-
This plugin does not support mandatory publishing and returns. This is explicitly mentioned in the Limitations section. Mandatory publishing and delayed publishing in combination make no sense: there is no way the plugin |
Beta Was this translation helpful? Give feedback.
-
TraceId=20210902990583 - 2021-09-02 16:43:54.442|http-nio-8086-exec-6|INFO |com.code.springboot.zhoujl.common.interceptor.HttpBaseInterceptor|preHandle|32 -> 开始访问:http://localhost:8086/test/sendDelayMsg
TraceId=20210902990583 - 2021-09-02 16:43:54.443|http-nio-8086-exec-6|INFO |com.code.springboot.zhoujl.common.interceptor.HttpBaseInterceptor|preHandle|33 -> ip地址:172.35.0.18
msg= 我来发一个测试消息,10秒.delayTime10000
2021-09-02 16:43:54 Delay sent.
msg= 我来发一个测试消息,20秒.delayTime20000
2021-09-02 16:43:54 Delay sent.
msg= 我来发一个测试消息,30秒.delayTime30000
2021-09-02 16:43:54 Delay sent.
TraceId=20210902990583 - 2021-09-02 16:43:54.553|http-nio-8086-exec-6|INFO |com.code.springboot.zhoujl.common.interceptor.HttpBaseInterceptor|afterCompletion|43 -> 结束加载请求:http://localhost:8086/test/sendDelayMsg,总用时:109ms
收到延时消息时间:2021-09-02 16:44:04 Delay sent.
收到延时消息:"我来发一个测试消息,10秒"
收到延时消息时间:2021-09-02 16:44:14 Delay sent.
收到延时消息:"我来发一个测试消息,20秒"
收到延时消息时间:2021-09-02 16:44:24 Delay sent.
收到延时消息:"我来发一个测试消息,30秒"
News can be consumed successfully
//rabbitMq config rabbitMq version 3.9 plus version 3.9
@slf4j
@EnableRabbit
@configuration
public class RabbitMqConfig implements RabbitListenerConfigurer {
}
//Binding settings
@configuration
public class RabbitConfig {
public static final String IMMEDIATE_QUEUE_XDELAY = "queue.xdelay.immediate";
public static final String DELAYED_EXCHANGE_XDELAY = "exchange.xdelay.delayed";
public static final String DELAY_ROUTING_KEY_XDELAY = "routingkey.xdelay.delay";
@bean
public Queue immediateQueue() {
}
Thank you
Beta Was this translation helpful? Give feedback.
All reactions