Rabbitmq RPC请求报出rabbitmq no correlation header in reply

问题说明

在springboot中使用rabbitTemplate.convertSendAndReceive方法发送rpc请求，报出rabbitmq no correlation header in reply错误

问题原因

server端没有取出请求信息correlation_id，并存入返回信息中，导致rpc返回信息中没有 correlation_id

解决办法

server端获取请求信息的correlation_id，并存入返回信息

amqpTemplate.convertAndSend(replyTo, (Object) result, new MessagePostProcessor(){

                    @Override
                    public Message postProcessMessage(Message message) {
                        message.getMessageProperties().setCorrelationId(correlationId);
                        return message;
                    }