Описание тега spring-rabbitmq
Компоненты Spring для обмена сообщениями на основе AMQP.
1
ответ
Объявление очереди на всех узлах в RabbitMQ
У меня есть установка кластера Rabbitmq (без HA). Мои потребители - это пружинные приложения, и он обеспечивает механизм восстановления после сбоя из коробки, где он подключается к следующему доступному узлу. Поскольку очереди не зеркально отражены,…
16 июн '17 в 02:20
1
ответ
RabbitMqListener не слушает должным образом для тех же самых клавиш маршрутизации
У меня есть требование, где я должен слушать один и тот же обмен, одну и ту же очередь, но разные маршруты. ниже приведен код для прослушивания сообщений от diff маршрутов @Component public class EmailMessageHandler { @RabbitListener(bindings = @Que…
07 фев '17 в 21:32
1
ответ
Несвязанный Fanout Exchange теряет данные
Когда я передаю несколько сообщений на обмен Fanout (который еще не связан ни с какой очередью) и останавливаю издателя, сообщения, отправленные на обмен, теряются. Обмен останавливается. Возможно ли, что несвязанный Exchange может содержать опублик…
06 май '17 в 08:21
1
ответ
RabbitMQ Не удалось объявить очередь, и слушатель не может получить очередь на сервере
У меня есть приложение rabbitmq для весенней загрузки, в котором я должен отправить объект Employee в очередь. Затем я настроил приложение для прослушивания. Сделайте некоторую обработку на объекте работника и поместите этот объект в очередь обратно…
17 мар '18 в 08:53
1
ответ
О rabbitmq, как этого добиться, если за 10 секунд не получат ни одного сообщения, выбросить исключение или выполнить какой-либо метод?
Я использую весеннюю загрузку и rabbitmq. Как этого добиться, если за 10 секунд не получит ни одного сообщения, сгенерировать исключение или выполнить какой-либо метод? Я пытаюсь использовать многопоточность, но не закончил. Мне нужна помощь, спасиб…
12 июл '17 в 13:47
1
ответ
Извлекать заголовки из сообщения, используя spring-rabbit, без объявления очередей в аннотации
Теперь я могу сделать так: @RabbitListener(queues = {ENTITY_KEY + "-snapshots", ENTITY_KEY + "-updates"}) public void handleMessage(ProviderOddsOffer offer, @Header("update_type") Long updateType) { ... } Могу ли я сделать это без объявления очереде…
24 апр '15 в 15:34
1
ответ
Каков правильный тип исключения для NACK-сообщения с использованием прослушивателя на основе аннотаций при загрузке с использованием amqp?
Я использую Spring Boot со Spring-amqp и слушателем на основе аннотаций, чтобы получить сообщение от брокера rabbitmq. У меня есть компонент Spring, который содержит такой метод: @RabbitListener(queues = "tasks") public void receiveMessage(@Payload …
29 авг '16 в 18:11
2
ответа
Spring RabbitTemplate- Как получить опубликованное сообщение для NACK в режиме подтверждения Publisher
У меня есть веб-приложение, которое отправляет сообщения на RabbitQueue с помощью Spring. Я включил Publisher, подтвердил и включил возврат, и я использую шаблон весны кролика:. Это моя конфигурация: <rabbit:template id="amqpTemplate" connection-…
07 дек '15 в 01:32
1
ответ
Spring AMQP RabbitMQ - Обработка ошибок для прямого ответа
Я пытаюсь обработать исключения, которые возникают из-за amq.rabbitmq.reply-to-очереди, в частности таких вещей, как: "org.springframework.amqp.AmqpRejectAndDontRequeueException: Ответ получен после тайм-аута". Как я могу что-то настроить, чтобы спр…
12 дек '18 в 20:06
1
ответ
Весенний AMQP. Обмен письмами. Отправить сообщение в исходную очередь
В моей системе я использую Тематические Обмены с большим количеством очередей потребителей. Каждая очередь имеет собственный неуникальный ключ маршрутизации (например, "add. #" Для всех новых объектов или просто "#" для использования всех событий).Я…
16 авг '18 в 16:47
2
ответа
Как использовать RMQ и весенний облачный поток для создания потребителя на основе разделов
Я могу разработать образец потребителя, используя облачный поток и rabbit mq, если у меня есть 3 раздела, созданные производителем, и если я разверну 3 экземпляра в CF, каждый выбирает одну очередь и обрабатывает сообщения с использованием индекса, …
27 апр '17 в 14:46
1
ответ
Spring AMQP - Очередь сообщений с использованием механизма мертвых букв с TTL
Это как "Хьюстон, у нас здесь проблема", когда мне нужно запланировать / задержать сообщение на 5 минут после того, как оно не сработает при первой попытке обработать событие. В этом сценарии я реализовал обмен мертвыми буквами. Сообщения о сбое нап…
21 дек '16 в 08:53
2
ответа
Обработка сообщения от rabbitmq с указанной скоростью
Мы пытались заставить слушателя читать сообщения от rabbitmq с определенной скоростью 1 мсг /2 секунды. Мы не нашли такой утилиты с rabbit mq. Так что подумайте о том, чтобы сделать это с БД, т.е. слушатель будет читать сообщения и сохранять их в БД…
06 ноя '16 в 07:26
1
ответ
Интеграционные тесты SpringBoot / RabbitMq больше не работают в другой среде
У меня есть набор тестов, работающий нормально на подчиненном устройстве Windows Jenkins и локально (на Windows), и теперь мы переносим наше ведомое устройство Jenkins на образ Docker Linux. Сборка, которая была в порядке, не работает должным образо…
19 июн '17 в 05:10
4
ответа
MessageConversionException: не удалось преобразовать содержимое сообщения
У меня есть приложение SpringBoot, которое использует Spring AMQP. В настоящий момент я реализую его на стороне получателя, используя классы JavaConfig, как указано в официальных примерах Spring docs. Тем не менее, я получаю MessageConversionExcepti…
25 окт '16 в 13:03
3
ответа
RabbitTemplate для подключения к RabbitMQ: получение - NOT_FOUND - без очереди
Я новичок в весне и работаю над облачным приложением и пытаюсь использовать RabbitTemplate и RabbitMQ. Я могу хранить данные в очереди с помощью. rabbitTemplate.convertAndSend(QUEUE_NAME, msg); Но когда я получаю данные из той же очереди, используя …
13 сен '16 в 06:22
1
ответ
Spring RabbitMq - слушатель событий, созданный в очереди
Я хотел бы знать, если какие-либо события публикуются, когда queue на самом деле физически создан в Rabbitmq с помощью Spring Api, Причина, по которой я спрашиваю, так или иначе, у нас есть состояние гонки. Подписка на queue как-то обычно занимает б…
09 мар '17 в 10:20
1
ответ
Балансировка нагрузки Haproxy Sockjs Websocket и балансировка нагрузки RabbitMQ в одной конфигурации
Я ищу конфигурацию haproxy (HAProxy версии 1.5.18), которая позволит балансировать нагрузку веб-сокета, а также балансировку нагрузки RabbitMQ. Я перепробовал много вариантов, но ни один из них не работает, ниже мой файл конфигурации haproxy: global…
08 сен '17 в 21:08
1
ответ
Rabbitmq удаляет сообщения из физического хранилища
У меня есть долговременные обмены и очереди в моем приложении. Сообщения тоже постоянны. Используя эту конфигурацию, я уверен, что мои сообщения хранятся в физической памяти. Я хочу знать, есть ли время истечения, когда rabbitmq удаляет сообщения из…
21 апр '18 в 05:41
1
ответ
Spring Boot RabbitMQ Ошибка исключения нулевого указателя
Я использую RabbitMQ с Spring Boot для обмена сообщениями между двумя службами. Я могу получить сообщение и отформатировать его, но когда я вызываю класс службы в методе onMessage, я получаю ошибку исключения нулевого указателя. Вот мой класс слушат…
11 авг '18 в 22:01