Ручная конечная точка подтвердила успешное создание очередей /обменов через репликацию на основе кода. Инициализирован. < /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
@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