Ich verwende Spring Cloud Stream mit RabbitMQ-Binder. Es funktioniert gut mitbyte[] Payload und native Java-Serialisierung, aber ich muss mit JSON-Payload arbeiten.

Hier ist meine Prozessorklasse.

@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 undOutputDto sind POJOs mit Jackson-Anmerkungen.

Wie konfiguriere ich die JSON-Konvertierungsstrategie?Wie sollten Nachrichtenkopfzeilen aussehen, um akzeptiert und verarbeitet zu werden?