spring-amqp

1зной

1ответ

spring amqp ConfirmCallback CorrelationData имеет значение null иногда

Включить публикацию подтверждения и вызвать метод отправки RabbitTemplate с помощью CorrelationData. Но когда я получаю CorrelationData в ConfirmCallback, иногда CorrelationData имеет значение null и

1зной

1ответ

Какова лучшая стратегия обработки исключений весной amqp SimpleMessageListenerContainer

У меня есть два путаницы. 1.Если RuntimeException выбрано из прослушивателя сообщений, то SimpleMessageListenrContainer останавливается? 2.Если SimpleMessageListenerContainer не останавливается, что т

2зной

1ответ

Каким будет поведение создания одного RabbitListenerContainerFactory с двумя пользователями и несколькими конечными точками для прослушивания сообщений

У меня есть требование, когда у меня есть 1 прямой обмен и 5 разных очередей привязываются к нему с помощью уникального ключа маршрутизации. В основном каждая очередь предназначена для разных конечных

1зной

2ответ

Переопределение реализации по умолчанию org.springframework.amqp.rabbit.connection.CachingConnectionFactory

Мы с помощью клиента Spring AMQP для подключения к нашим RabbitMQs и наша Spring Config определяется как <bean id="nativeCF" class="com.rabbitmq.client.ConnectionFactory" p:connection-timeout="#{msgPr

1зной

2ответ

Уведомление об отключении канала для классов, реализующих org.springframework.amqp.rabbit.connection.ConnectionListener

Мы используем интерфейс ConnectionListener, предоставляемый Spring-AMQP, чтобы сохранить вкладку в базовом соединении. Канал создается с автообнаружением с биением, установленным на 10 минут (для неко

-2зной

1ответ

Classnotfoundexception вызывает SimpleMessagelistenerContainer stop

Я обнаружил, что, когда слушатель бросает classnotfoundexception, simplemessagelistenercontainer останавливается и не работает для сообщения последовательности. Я установил defaultrejectqueue false, д