Я использую Spring Cloud Stream, со связующим RabbitMQ. Отлично работает сbyte[] полезная нагрузка и нативная сериализация Java, но мне нужно работать с полезной нагрузкой JSON.

Вот мой класс процессора.

@EnableBinding(Processor.class)
public class MessageProcessor {
    @ServiceActivator(inputChannel = Processor.INPUT, outputChannel = Processor.OUTPUT)
    public OutputDto handleIncomingMessage(InputDto inputDto) {
        // Run some job.
        return new OutputDto();
    }
}

InputDto а такжеOutputDto POJO с аннотациями Джексона.

Как настроить стратегию преобразования JSON?Как должны выглядеть заголовки сообщений, которые будут приняты и обработаны?