带回调的RabbitTemplate异步消息

Question

@Autowired(required = false)
@Qualifier("rabbitTemplate")
private RabbitTemplate queueTemplate;

@Override
public Response createIncident(String incident) {
    LOGGER.info("Sending incident into queue");
    queueTemplate.convertAndSend((Object)incident, new MessagePostProcessor() {

        @Override
        public Message postProcessMessage(Message message) throws AmqpException {
            message.getMessageProperties().setReplyTo("replyQueue");
            return message;
        }
    });
    Message message = queueTemplate.receive();
...

<rabbit:admin connection-factory="rabbitConnFactory" />

<rabbit:queue name="rabbitQueue" />
<rabbit:queue name="replyQueue" />

<rabbit:topic-exchange name="rabbitExchange">
    <rabbit:bindings>
        <rabbit:binding queue="rabbitQueue" pattern="camel" />
        <rabbit:binding queue="replyQueue" pattern="camel" />
    </rabbit:bindings>
</rabbit:topic-exchange>


<rabbit:template id="rabbitTemplate" 
    connection-factory="rabbitConnFactory" exchange="rabbitExchange" routing-key="camel"
    reply-address="replyQueue" reply-queue="replyQueue">
    <rabbit:reply-listener/>
</rabbit:template>

<rabbit:listener-container
    connection-factory="rabbitConnFactory" concurrency="10">
    <rabbit:listener ref="rabbitMessageListener" method="createIncident"
        queue-names="rabbitQueue" />
</rabbit:listener-container>

<bean id="rabbitMessageListener" class="com.my.listener.QueueListener" />

和响应的侦听器

@Autowired(required = false)
@Qualifier("rabbitTemplate")
private RabbitTemplate queueTemplate;

public void createIncident() {
    queueTemplate.receiveAndReply("replyQueue", new ReceiveAndReplyMessageCallback() {

        @Override
        public Message handle(Message message) {
            String incident = new String(message.getBody());
            LOGGER.debug("Queue incoming message: " + incident);
            String result = "" + messageHandler.createIncident(incident);
            return new Message(result.getBytes(), new MessageProperties());
        }

    }); 

它不想进入侦听器中的这个句柄消息。和应用程序容器显示消息

Answer 1

您应该使用：

/**
 * The name of the default queue to receive messages from when none is specified explicitly.
 *
 * @param queue the default queue name to use for receive
 */
public void setQueue(String queue) {
    this.queue = queue;
}

而不是回复地址。

重新考虑你的

queueTemplate.receiveAndReply("replyQueue",