Потребительский бон Rabbitmq не инициализирован в среде EKS (Pre-Prod), несмотря на успешное создание очередей и обменаJAVA

Программисты JAVA общаются здесь
Ответить Пред. темаСлед. тема
Anonymous
 Потребительский бон Rabbitmq не инициализирован в среде EKS (Pre-Prod), несмотря на успешное создание очередей и обмена

Сообщение Anonymous »

Я устраняю устранение критического несоответствия между средами при использовании Rabbitmq с пружинной загрузкой. Приложение прекрасно работает в локальном и разработке (EC2) , но в pre-production (EKS) , бобы для слушателя потребителей и боб Retry Interceptor вообще не инициализируются. /> очереди, обмены и привязки создаются успешно (с помощью перезагрузки и настройки бобов Amqpadmin). < /p>
Ручная конечная точка подтвердила успешное создание очередей /обменов через репликацию на основе кода. Инициализирован. < /p>
Нет журналов из метода @RabBitListener. Журналы отладки, указывающие на неудачу; Все кажется успешным до этой точки. Заказ.

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

    @RabbitListener(
queues = STUDENT_ATHLETE_UPLOAD_QUEUE,
containerFactory = "rabbitListenerContainerFactorySync")
public void consumeNewSAForAddingToFutureEvents() {}
< /code>
Factory Bean: < /p>
@Bean("rabbitListenerContainerFactorySync")
@Lazy
@DependsOn({"connectionFactory", "converter", "retryInterceptor"})
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactorySync(...) {
LOGGER.info("Initializing RabbitListenerContainerFactory with retry logic");
...
}
bean Repry Interceptor (также никогда не инициализируется):
@Bean
@DependsOn({"amqpTemplate", "converter"})
public RetryOperationsInterceptor retryInterceptor(
AmqpTemplate amqpTemplate, MessageConverter converter) {
LOGGER.info("Creating retry interceptor"); // this log never appears
...
}
< /code>
Что я пробовал: < /strong>
Проверенные проблемы с брандмауэром, исходящим или DNS (подтверждено сетевой командой и поддержкой CloudAMQP). < /p>
Обеспечивают все зависимые бобы, такие как Amqpadmin, ConnectionFactory и Rabtemplate, инициализируются. RabbitMQ доступен, а создание очередей/обмена достигается успешно.
Пробое использовал @lazy, переупорядоченные зависимости от бобов с @dependson и добавлена ​​защитная ведение. Потребительский боб и фабрика слушателя не инициализируются в EKS, даже несмотря на то, что все компоненты RabbitMQ Upstream успешно настроены? Cloudamqp?

Подробнее здесь: https://stackoverflow.com/questions/796 ... espite-suc
Реклама
Ответить Пред. темаСлед. тема

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

  • Похожие темы
    Ответы
    Просмотры
    Последнее сообщение

Вернуться в «JAVA»