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.