Spring Cloud Bus, RenamingMQ в более удобочитаемом виде

У моего Cleint есть 2 экземпляра, и я использую приведенный ниже фрагмент для переименования очереди и вижу, что testExchange.testQueue создан, под которым я вижу 2 потребителя, т.е. экземпляры моего клиента, но пока / bus / refresh я вижу, что обновляется только один экземпляр и я не получаю функцию Cloud Bus, а именно / bus / refresh, все экземпляры должны быть обновлены, пожалуйста, дайте мне знать, если мне не хватает какой-либо конфигурации для переименования очереди в удобочитаемом формате.

spring:
 cloud:
   stream:
     bindings:
       springCloudBusInput:
         destination: testExchange
         group: testQueue
   config:
     bus:
       enabled: true
     uri: https://Config-Server-offshore.com/
     name: ClientApp

1 ответ

С помощью Spring-cloud-stream, используя group создает конкурирующих потребителей в одной очереди.

Если вы удалите group каждый экземпляр получит свою очередь.

Вы можете использовать заполнитель в группе, чтобы сделать его уникальным...

spring.cloud.stream.bindings.input.group=${instanceIndex}
instanceIndex=1

... если вы работаете в облачной среде, вы можете использовать индекс экземпляра vcap.

Другие вопросы по тегам