Estou usando o Spring Cloud Stream, com o encadernador RabbitMQ. Funciona muito bem combyte[] carga útil e serialização nativa Java, mas preciso trabalhar com carga JSON.

Aqui está a minha classe de processador.

@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 eOutputDto são POJOs com anotações de Jackson.

Como configurar a estratégia de conversão JSON?Como os cabeçalhos das mensagens devem ser aceitos e processados?