RabbitMQ的延迟功能不起作用

Question

我在春季启动时使用RabbitMQ通过微服务发送消息。我需要为每条消息设置延迟选项。在这种情况下，我将MessageProperties文件与Message一起使用，它喜欢这样。

MessageProperties properties = new MessageProperties();
properties.setDelay(15000);
properties.setContentType(ContentType.APPLICATION_JSON.getMimeType());
properties.setType("direct");
properties.setHeader("x-delay",15000);
properties.setHeader("x-delayed-type","direct");
properties.setHeader("x-delayed-message",true);
Message forSms = MessageBuilder.withBody(SerializationUtils.serialize(updatedAppointment.getId())).andProperties(properties).setCorrelationId(correlationIdForSms.getBytes()).setHeader("x-delay", 20000).setHeaderIfAbsent("x-delay", 20000).build();
rabbitTemplate.send("auto.exch", "orderRoutingKey", forSms);
and I handle it in this function:
@RabbitListener(bindings = @QueueBinding(
value = @Queue(value = "myQueue", durable = "true"),arguments = @Argument(name = "x-delay",value = "15000",type = "java.lang.Integer"),
exchange = @Exchange(value = "auto.exch", delayed ="true",ignoreDeclarationExceptions = "true",arguments = @Argument(name = "x-delayed-type",value = "direct"), type = ExchangeTypes.HEADERS),
key = "orderRoutingKey")
)
public void sendMessagePatientPhone(final Message message) throws EntityNotFoundException {
Long appointmentId = (Long) SerializationUtils.deserialize(message.getBody());
String correlationId = new String(message.getMessageProperties().getCorrelationId());

Appointment appointment = appointmentService.findById(appointmentId);
User user = appointment.getPatient().getUser();
String msg = "Teleconference is started after " + formattedTime(user.getNotificationPeriodForSms());
sendSms(user, msg);
}

但我得到的只有空的标题和消息没有延迟。也许我用错了方法，但我需要正确的解决方案。我的基本目标是用特定的时间延迟每条消息

Answer 1

您似乎有一些困惑：

properties.setHeader("x-delayed-type","direct");
properties.setHeader("x-delayed-message",true);

这些属性是交换属性，而不是消息属性。

要设置x-delay属性，只需使用properties.setDelay(15000)即可。

Answer 2

我已经完成了。问题与RabbitMQ的插件有关，该插件是RabbitMQ_delayer_message_exchange。我安装并启用了它。之后x-delay功能工作