春云的反序列化

我有一个内容类型配置如下的生产者

spring:
  cloud:
    stream:
      bindings:
        eventOut:
          destination: lab_csi
          content-type: application/json

在消费者方面,我使用Spring集成(KysSeriMeDigaRihanChhanelAdvor)将事件路由到不同的通道。

@ServiceActivator(inputChannel = "channelA")
    void handleMessage(Message<?> msg) {
        objectMapper.readValue(msg.getPayload(), MyEvent.class);
    }

编组到MyStEvices失败。在堆栈错误中,我可以看到内容类型是有效载荷的一部分,有效载荷还没有从JSON到波霍反序列化。

我想知道如何在进行任何其他转换之前反序列化消息。我找不到任何方法可以将MessageConverter设置为适配器。

谢谢你的帮助。

谢谢你