Вопросы по теме 'spring-rabbit'
RabbitMQ: отдельные партнеры потребителя и производителя при использовании только одного сервера очереди
мы собираемся использовать rabbitmq в нашем проекте, но столкнулись с проблемой, которую мы хотим отлаживать на наших машинах разработчика, поэтому ответное сообщение должно быть отправлено на машину, которая изначально отправила сообщение запроса....
518 просмотров
schedule
02.12.2021
Повторно ставьте сообщения AMQP кролика в хвост очереди после максимального количества попыток
В настоящее время я использую RabbitMQ с пружиной (spring-rabbit-1.2.0-RELEASE) со следующей конфигурацией:
<rabbit:template id="amqpTemplate" connection-factory="connectionFactory"/>
<!-- Asynchronous exchanges -->
<!-- Admin...
5628 просмотров
schedule
30.11.2021
Как подтвердить сообщение с другого канала RabbitTemplate?
Предположим, у меня есть единственный экземпляр rabbitTemplate, и я вызываю rabbitTemplate.send （Message）, чтобы опубликовать сообщение на сервер RabbitMQ.
Вот что я хочу сделать: 1. с точки зрения издателя, как убедиться, что сообщение получено...
2161 просмотров
schedule
09.11.2021
Связь по шине сообщений Spring REST
Я ищу модуль Spring, который может помочь мне интегрировать веб-службы Spring REST с шиной сообщений (RabbitMQ). Веб-служба REST выступает в роли потребителя сообщений AMQP от клиента. Всякий раз, когда сообщения отправляются по шине, это сообщение...
2862 просмотров
schedule
02.10.2021
Аннотации Spring Amqp на основе
Я новичок в Spring AMQP и хочу использовать конфигурацию на основе аннотаций как для производителей, так и для потребителей, использующих последнюю версию Spring amqp 1.5.4,
Доступен ли для конфигурации какой-либо псевдо-код, который выполняет...
387 просмотров
schedule
07.11.2021
Весеннее сообщение о приоритете AMQP
Приоритеты сообщений в очередях в RabbitMQ. Он работает с Java-клиентом, предоставленным rabbitmq. Но это не работает с зависимостью spring-rabbit. Пожалуйста, посмотрите.
Версия сервера RabbitMQ - 3.6.5
Эрланг - OTP 19 (8.0)...
2222 просмотров
schedule
12.10.2021
Как получить заказ для разных MessagePostProcessors в SimpleMessageListenerContainer
У меня есть несколько MessagePostProcessors в SpringAMQP, которые я установил с помощью SimpleMessageListenerContainer.setAfterReceivePostProcessors API, теперь мой запрос: вызываются ли эти MessagePostProcessors в указанном мной порядке.
Код...
125 просмотров
schedule
11.10.2021
Потеряно ли сообщение, если при публикации сообщения в RabbitMQ возникает проблема, не имеющая отношения к сети?
Я использую Spring AMQP для публикации сообщений в RabbitMQ. Рассмотрим сценарий: 1. Клиент Java отправляет сообщение в MQ, используя amqpTemplate.convertAndSend () 2. Но RabbitMQ не работает ИЛИ возникла некоторая проблема, связанная с отсутствием...
291 просмотров
schedule
01.11.2021
Spring data rabbitmq @RabbitListener внезапно перестал принимать сообщения в очереди
Я использую выпуск spring boot 2.1.1 и spring-boot-starter-amqp, @@ RabbitListener перестал принимать сообщения, хотя работал нормально. Когда я перезапустил потребительский API, он начал нормально работать.
Также из пользовательского интерфейса...
309 просмотров
schedule
05.09.2021
Могу ли я изменить параметры пружины при выполнении?
У меня есть приложение, которое использует динамических потребителей. Я использую Spring Framework с RabbitMQ.
У меня есть такие параметры, как concurrentConsumers и maxConcurrentConsumers .
Вот пример:
@Bean
public...
162 просмотров
schedule
22.02.2022
Использование очереди на основе количества потребителей в Spring AMQP
Я хочу, чтобы очередь использовалась только одним подписчиком одновременно. Таким образом, если один подписчик откажется, то у другого будет возможность подписаться.
Я ищу правильный способ сделать это в Spring AMQP. Я сделал это на чистой Java,...
1350 просмотров
schedule
22.02.2022
Spring AMQP (RabbitMQ) Ошибка отключения канала выброса
Я пытаюсь сделать channel.basicReject() повторно поставить сообщение в очередь на основе некоторого условия, создав MethodInterceptor ConsumerAdvice и добавив его в SMLC factor.setAdviceChain(new ConsumerAdvice()) . У меня также есть...
928 просмотров
schedule
28.02.2022
Интеграция Spring - Издатель подтверждает тайм-аут?
Это моя текущая установка:
queue1 и queue2 объединяются вместе с потоком интеграции в channel1:
@Bean
public IntegrationFlow q1f() {
return IntegrationFlows
.from(queue1InboundAdapter())
......
1299 просмотров
schedule
08.03.2022
Spring Cloud Stream с Rabbit Binder - имена очередей источника / приемника не совпадают
Недавно я начал играть со связующим Spring Cloud Stream и RabbitMQ.
Если я все правильно понял, когда две службы хотят передать сообщение, один должен настроить источник для отправки сообщений, а другой должен настроить приемник для получения...
7005 просмотров
schedule
22.03.2022
Избегайте отправки сообщения верблюдом в очередь, когда RabbitMQ не работает
Я новичок в RabbitMQ и Apache-Camel. Сообщения отбираются через интерфейс (IMAP и т. Д.) И отправляются в очередь для дальнейшей обработки. Я изо всех сил пытаюсь найти решение, чтобы избежать потери сообщений в сценарии, когда RabbitMQ не работает....
267 просмотров
schedule
22.03.2022
Метод spring-amqp onMessage () не обрабатывает следующее сообщение, когда выполняется обработка предыдущего сообщения
Я использую MessageListener для чтения сообщений из указанной очереди и хочу выполнить обработку, как только я получу сообщение в очереди.
Вот мой код
@Bean
public MessageListenerContainer messageListenerContainer()
{...
195 просмотров
schedule
09.04.2022
Spring AMQP RabbitListener для подключения к 2 кластерам кроликов
У меня есть один метод прослушивателя, помеченный @RabbitListener , в настоящее время он настроен для прослушивания из 1 кластера кроликов. Теперь у меня есть еще один кластер кроликов (cluster2) с тем же ключом очереди / обмена / маршрутизации, и...
172 просмотров
schedule
12.04.2022
Выключение канала: ошибка канала: код-ответа = 406, текст-ответа = PRECONDITION_FAILED - получатель ответа уже установлен
Я запускаю несколько тестов с spring-amqp , spring-rabbit . Мой родительский элемент Maven - это spring-boot-starter-parent: 1.2.3.RELEASE , который извлекает:
spring-rabbit:1.4.3.RELEASE
spring-amqp:1.4.3.RELEASE
amqp-client:3.4.2...
6549 просмотров
schedule
16.04.2022
в Spring amqp как инкапсулировать RabbitListener на высоком уровне
Я использую spring amqp в своем проекте, и я использую реализации ChannelAwareMessageListener для повторной отправки и обработки исключения, чтобы сделать слушателя кролика более стабильным:
public abstract class AbstractMessageListener...
781 просмотров
schedule
24.04.2022
Производитель уже предоставленного RabbitMq через Spring Cloud Stream
Я нахожусь в среде, где rabbitmq уже предоставлены как заданная инфраструктура.
Служба A выполняет запись в очереди кроликов, а Служба B читает из очередей. Часть чтения в качестве потребителя через Spring Cloud Stream Binder работает как...
401 просмотров
schedule
24.05.2022
