Camel rabbitmq + convertSendAndReceive():无法使用content-type [null]转换传入的消息

Question

我有一个组件,它向等待结果的工作服务发送消息.

@Autowired
private RabbitTemplate rabbit;
[...]
Object response = rabbit.convertSendAndReceive("testQ", ...);

使用Apache Camel rabbitmq路由实现工作服务:

from("rabbitmq://localhost/myExchange?declare=false&routingKey=testQ&queue=testQ")
        .routeId("myCamelRoute")
        .process(myProcessor)
        .to("log:myLog");

myProcessor处理消息并注销Camel消息头:

__TypeId__=...
breadcrumbId=...
rabbitmq.CONTENT_ENCODING=UTF-8
rabbitmq.CONTENT_TYPE=application/json
rabbitmq.CORRELATIONID=7e390b6b-d30f-4f26-ba44-33fb887db0e8
rabbitmq.DELIVERY_TAG=4
rabbitmq.EXCHANGE_NAME=
rabbitmq.PRIORITY=0
rabbitmq.REPLY_TO=amq.rabbitmq.reply-to.g2dkABNyYWJiaXRAOWU5ZjkxNDI4ZWRiAAAJgwAAADUC.5+kPXXxaXhoYo7A4T0HSZQ==
rabbitmq.ROUTING_KEY=testQ

消息头显然在工作端包含rabbitmq.CONTENT_TYPE = application/json,但当响应消息返回时,此信息似乎"丢失":

osascJackson2JsonMessageConverter:无法使用content-type [null]转换传入消息

知道这里有什么问题吗？

Answer 1

使用Headers字段时,我看到使用RabbitMQ管理控制台时出现同样的错误.传递"content_type":"application/json"作为消息属性工作正常.