Как настроить очереди ответов rabbitmq, используя spring-amqp?

Question

Мы пытаемся сделать асинхронный вызов в RabbitMQ с использованием Spring AMQP, может ли кто-нибудь рассказать мне, как настроить answerqueue, correId, (свойства) с помощью Spring amqp?

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)); 

НТН