小编Rua*_*Tre的帖子

我的情况.我有完整的交付时间队列容器元素.我在春季启动时使用rabbitmq工具来支持.现在我应该将消息发送到队列,并在延迟时间队列将传递消息.Rabbitmq支持rabbitmq-delayed-message-exchange插件来安排消息.但我没有实施.我的代码有什么问题.(我启用了插件延迟)

@Bean
DirectExchange directExchange() {
    Map<String, Object> args = new HashMap<String, Object>();
    args.put("x-delayed-type", "x-delayed-message");
    return new DirectExchange("my-exchange", true, false, args);
}

@Bean
Binding binding(Queue queue, DirectExchange directExchange) {
    return BindingBuilder.bind(queue).to(directExchange).with(queueName);
}

"应答后"按钮应仅用于问题的完整答案.