Как установить свойство 'x-message-ttl' для очереди в java

Question

Как установить свойства 'x-message-ttl' для этой очереди?

rabbit:
            bindings:
              TEST_RESPONSE:
                consumer:
                  bindingRoutingKey: "'${routing}'"
                  prefetch: ${prefetch}
                  acknowledge-mode: MANUAL
          bindings:
            TEST_RESPONSE:
              destination: TEST_RESPONSE
              content-type: application/json
              group: test

потому что есть эта ошибка

Channel shutdown: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - inequivalent arg 'x-message-ttl' for queue 'TEST_RESPONSE.test' in vhost '/': received none but current is the value '60000' of type 'long', class-id=50, method-id=10)

Answer 1

Определения очереди неизменны; Вы не можете изменить аргумент очереди.

Вам нужно либо отключить объявление очереди

...rabbit.bindings.foo.consumer.bindQueue: false

, либо добавить

...rabbit.bindings.foo.consumer.ttl: 60000

, чтобы соответствовать существующему определению.

См. Потребительские свойства.

https://cloud.spring.io/spring-cloud-static/spring-cloud-stream-binder-rabbit/3.0.3.RELEASE/reference/html/spring-cloud-stream-binder-rabbit.html#_rabbitmq_consumer_properties