set/getCorrelationIdString不起作用

Question

令我惊讶的是，Set/getCorrelationIdString不适合我。它是amqp-client 3.6.5和其他spring-rabbit/amqp 1.6.6。还有没有人面对它？我只能使用Set/getCorrelationId，它可以工作，但显示为已折旧。任何针对此的解决方案。

Answer 1

这是因为DefaultMessagePropertiesConverter的默认策略是：

private volatile CorrelationIdPolicy correlationIdPolicy = CorrelationIdPolicy.BYTES;

为了向后兼容。

如果您希望使用Set/getCorrelationIdString，您应该将DefaultMessagePropertiesConverter注入到RabbitTemplate中，并将SimpleMessageListenerContainer与CorrelationIdPolicy.STRING一起注入。