Spring Cloud Stream сообщение JSON преобразование не работает

Question

Я выполнил свой предыдущий вопрос Spring Cloud Stream message from/to JSON conversion configuration и сконфигурировал поток, как описано, но я не могу заставить его работать правильно.

Моя установка выглядит следующим образом. У меня есть два приложения: A и B. Приложение A использует входной канал one, выход two. Приложение B использует вход two. Канал two настроен с типом контента application/json.

App A. Свойства.

spring.cloud.stream.bindings.input.destination=one 
spring.cloud.stream.bindings.input.group=default 

spring.cloud.stream.bindings.output.destination=two 
spring.cloud.stream.bindings.output.content-type=application/json 

Метод приемника.

@ServiceActivator(inputChannel = Processor.INPUT, outputChannel = Processor.OUTPUT) 
public Dto handle(byte[] payload) throws IOException { 
    final Dto dto = new ObjectMapper().readValue(payload, Dto.class); 
    logger.info("{}", dto); 
    dto.setId(dto.getId() + 1000); 
    return dto; 
} 

App B. Свойства.

spring.cloud.stream.bindings.input.destination=two 
spring.cloud.stream.bindings.input.group=default 
spring.cloud.stream.bindings.input.content-type=application/json 

Метод приемника.

@ServiceActivator(inputChannel = Sink.INPUT) 
public void handle(Dto dto) throws IOException { 
    logger.info("DTO {}", dto); 
} 

Когда я вручную отправить сообщение с надлежащей строкой JSON к каналу one, он правильно обработан и отправить на канал two в виде сообщения JSON (заголовки точно так же, как описано в упомянутом выше вопросе). После этого он получил на канале two на App B и исключение: Method handle(java.lang.String) cannot be found

Конечно, когда я создаю оба метода, обработки DTO и строку в качестве входных данных, он работает, но всегда метод Строки вызывается и должен десериализация полезная нагрузка.

Я где-то ошибаюсь? Как настроить метод с такой подписью: public Dto handle(Dto incoming)?

Answer 1

Вы должны изменить тип содержимого декларации ввода AppB в

application/x-java-object;type=your.package.Dto.

Как указано в вашем вопросе, конечно, вы принимаете только строки JSON.