Estoy usando Spring Cloud Stream, con la carpeta RabbitMQ. Funciona muy bien conbyte[] carga útil y serialización nativa de Java, pero necesito trabajar con la carga útil JSON.

Aquí está mi clase de procesador.

@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 yOutputDto son POJOs con anotaciones de Jackson.

¿Cómo configuro la estrategia de conversión JSON?¿Cómo deben verse los encabezados de mensajes para ser aceptados y procesados?