rabbitmq - 如何使用 spring-amqp 配置 rabbitmq 回复队列？

Question

我们正在尝试使用 Spring AMQP 在 RabbitMQ 中进行异步调用，有人可以告诉我如何使用 spring amqp 配置回复队列、correlationId、（属性）吗？

    String corrId = java.util.UUID.randomUUID().toString();

 BasicProperties props = new BasicProperties
                                .Builder()
                                .correlationId(corrId)
                                .replyTo(replyQueueName)
                                .build();

 channel.basicPublish("", requestQueueName, props, message.getBytes());

Answer 1

我假设您需要使用RabbitTemplate：

rabbitTemplate.convertAndSend(requestQueueName, myObj, new MessagePostProcessor() {
   Message postProcessMessage(Message message) throws AmqpException {
      message.getMessageProperties().setReplyTo(replyQueueName);
      return message;  
   }
}, new CorrelationData(corrId));

高温高压