Повторить привязку очереди к обмену RabbitMQ ⇐ JAVA

[Anonymous]

Используя Spring-Boot с RabbitMQ, я пытаюсь создать обмен, который может иметь n-количество очередей, по одной для каждого из микросервисов, чтобы каждый из них получал одно и то же сообщение.

Микросервис производителя имеет определен Fanout Exchange.
Каждый микросервис потребителя создает очередь и пытается подключить ее к обмену производителя

Когда производитель запускается первым, обмен создано. Запускаемые микросервисы Consumer привязываются к обмену Producer. Однако в случае, если потребительские микросервисы запускаются первыми, они не будут привязываться, поскольку пока не к чему привязываться, предоставляя этот журнал:

Код: Выделить всё

2020-01-13 22:24:49.640  INFO [,,,] 88649 --- [           main] o.s.a.r.c.CachingConnectionFactory       : Attempting to connect to: [localhost:5672]
2020-01-13 22:24:49.685  INFO [,,,] 88649 --- [           main] o.s.a.r.c.CachingConnectionFactory       : Created new connection: rabbitConnectionFactory#7746ae18:0/SimpleConnection@428ea503 [delegate=amqp://guest@127.0.0.1:5672/, localPort= 62282]
2020-01-13 22:24:49.726 ERROR [,,,] 88649 --- [ 127.0.0.1:5672] o.s.a.r.c.CachingConnectionFactory       : Channel shutdown: channel error; protocol method: #method(reply-code=404, reply-text=NOT_FOUND - no exchange 'abc-exchange' in vhost '/', class-id=50, method-id=20)
2020-01-13 22:24:50.748 ERROR [,,,] 88649 --- [ 127.0.0.1:5672] o.s.a.r.c.CachingConnectionFactory       : Channel shutdown: channel error; protocol method: #method(reply-code=404, reply-text=NOT_FOUND - no exchange 'abc-exchange' in vhost '/', class-id=50, method-id=20)
2020-01-13 22:24:52.754 ERROR [,,,] 88649 --- [ 127.0.0.1:5672] o.s.a.r.c.CachingConnectionFactory       : Channel shutdown: channel error; protocol method: #method(reply-code=404, reply-text=NOT_FOUND - no exchange 'abc-exchange' in vhost '/', class-id=50, method-id=20)
2020-01-13 22:24:56.763 ERROR [,,,] 88649 --- [ 127.0.0.1:5672] o.s.a.r.c.CachingConnectionFactory       : Channel shutdown: channel error; protocol method: #method(reply-code=404, reply-text=NOT_FOUND - no exchange 'abc-exchange' in vhost '/', class-id=50, method-id=20)
2020-01-13 22:25:01.794 ERROR [,,,] 88649 --- [ 127.0.0.1:5672] o.s.a.r.c.CachingConnectionFactory       : Channel shutdown: channel error; protocol method: #method(reply-code=404, reply-text=NOT_FOUND - no exchange 'abc-exchange' in vhost '/', class-id=50, method-id=20)
2020-01-13 22:25:01.807  INFO [,,,] 88649 --- [           main] o.s.a.r.l.SimpleMessageListenerContainer : Broker not available; cannot force queue declarations during start: java.io.IOException
2020-01-13 22:25:01.859 DEBUG [,,,] 88649 --- [           main] .b.c.i.c.AppConfig$CustomHttpTraceFilter : Filter 'httpTraceFilter' configured for use

Как настроить микросервисы Consumer (или Producer) на попытку привязать очереди к обмену Producer, даже если они были запущены до существования обмена.

Другой подход заключается в том, что Producer создает очереди динамически на основе начальной информации о микросервисах Consumer, которые затем будут прослушивать данную очередь. Однако проблема все равно останется: если очередь создается недостаточно быстро или потребитель создается до производителя, тогда прослушиватель выдает исключение

Подробнее здесь: https://stackoverflow.com/questions/597 ... q-exchange