set/getCorrelationIdString не работает

Question

Удивительно для меня Set/getCorrelationIdString не работает для меня. Это amqp-client 3.6.5 и другие весна-кролик/amqp 1.6.6. Кто-нибудь еще столкнулся с этим? Я выживаю с помощью Set/getCorrelationId, который работает, но показывает как обесцененный. Любое решение для этого.

Answer 1

Это потому, что DefaultMessagePropertiesConverter имеет стратегию по умолчанию, как:

private volatile CorrelationIdPolicy correlationIdPolicy = CorrelationIdPolicy.BYTES; 

Для обеспечения обратной совместимости.

Если вы хотите использовать Set/getCorrelationIdString, вы должны вводить DefaultMessagePropertiesConverter в RabbitTemplate и SimpleMessageListenerContainer с CorrelationIdPolicy.STRING.