Описание тега spring-rabbit
Spring components for AMQP-based messaging with RabbitMQ.
1
ответ
Объявление очереди на всех узлах в RabbitMQ
У меня есть установка кластера Rabbitmq (без HA). Мои потребители - это пружинные приложения, и он обеспечивает механизм восстановления после сбоя из коробки, где он подключается к следующему доступному узлу. Поскольку очереди не зеркально отражены,…
16 июн '17 в 02:20
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
1
ответ
java.lang.ClassCastException: JedisConnectionFactory не может быть приведен к ConnectionFactory
Я не уверен, почему метод "connectionFactory" возвращает экземпляр JedisConnecionFactory, если это не org.springframework.amqp.rabbit.connection.ConnectionFactory? Следующее исключение в строке "new RabbitTemplate(connectionFactory())" (см. Код ниже…
23 фев '15 в 12:10
1
ответ
Как предотвратить блокировку Spring AMQP на непрочитанных сообщениях?
У меня есть @RabbitListener аннотированный метод, для которого Spring AMQP блокируется после возврата из метода. Основной SimpleRabbitListenerContainerFactory использования AcknowledgeMode.MANUAL, Я пока не хочу подтверждать сообщение в методе слуша…
09 май '16 в 10:04
1
ответ
Весенний AMQP. Обмен письмами. Отправить сообщение в исходную очередь
В моей системе я использую Тематические Обмены с большим количеством очередей потребителей. Каждая очередь имеет собственный неуникальный ключ маршрутизации (например, "add. #" Для всех новых объектов или просто "#" для использования всех событий).Я…
16 авг '18 в 16:47
1
ответ
Должно ли изображение быть в кодировке base64 в сообщении JSON или возвращено как BytesMessage в Spring AMQP?
Я настроил базовый обмен запросами / ответами через Spring amqp с использованием POJO, и они обмениваются через RabbitMQ через конвертер сообщений JSON. До сих пор полезная нагрузка моего ответа pojo была простыми строками, но теперь мне нужно время…
22 июн '13 в 22:07
1
ответ
spring-amqp не работает правильно, когда соединения заблокированы
Я использую spring-amqp 1.4.4 и после того, как очередь содержит слишком много сообщений, и она находится над памятью водяного знака, метод приема RabbitTemplate не отвечает, если он был вызван после метода send. Это ждать бесконечно. А весной xml я…
14 дек '16 в 01:23
1
ответ
Интеграционные тесты SpringBoot / RabbitMq больше не работают в другой среде
У меня есть набор тестов, работающий нормально на подчиненном устройстве Windows Jenkins и локально (на Windows), и теперь мы переносим наше ведомое устройство Jenkins на образ Docker Linux. Сборка, которая была в порядке, не работает должным образо…
19 июн '17 в 05:10
1
ответ
Как RabbitMQ определяет, имеет ли очередь статус Active в инструменте управления
При входе в инструмент веб-управления очередь с "активным соединением" показывает состояние "Активно" в разделе подробностей очереди. Обратите внимание, что понятие активного соединения - мое собственное, так как я просто опрашиваю эту очередь через…
13 мар '12 в 23:17
1
ответ
org.springframework.beans.factory.NoUniqueBeanDefinitionException проблема с RabbitMQ
Я строю проект с весенней загрузкой, и я хочу объединиться RabbitMQ в моем проекте. Я использую весеннюю загрузку кролика MQ. Я хочу создать два экземпляра шаблона rabbit mq и для этого я дал эту конфигурацию package com.example.test; import org.spr…
16 ноя '15 в 05:48
2
ответа
Интеграция Spring AMQP - подтверждение для потребителя
Я тестирую Spring-AMQP с Spring-Integration поддержка, я имею следующую конфигурацию и тест: <rabbit:connection-factory id="connectionFactory" /> <rabbit:queue name="durableQ"/> <int:channel id="consumingChannel"> <int:queue cap…
10 янв '14 в 11:56
1
ответ
Получить имя очереди RabbitMQ, из которой было получено сообщение
Используя SimpleMessageListenerContainer который подключен к нескольким очередям и настроен с ChannelAwareMessageListener, Можно ли определить, из какой очереди было отправлено сообщение? В частности, если сообщение было перенаправлено в очередь из …
26 мар '14 в 08:54
0
ответов
Spring CachingConnectionFactory ограничивает каналы и вызывает блокировку потоков
У меня есть простой издатель сообщений, который публикует rabbitmq (местный) с очень высокой скоростью. ExecutorService threadPool = Executors.newFixedThreadPool(5, factory); for (int i = 1; i <= 1000000; i++) { int finalI = i; threadPool.submit(…
26 июн '17 в 20:47
1
ответ
Версия Spring-Amqp против Rabbitmq
Есть ли матрица или отображение, которые идентифицируют версии rabbitmq, которые можно использовать с каждой версией spring-amqp? В настоящее время мы используем rabbitmq 3.5.4 с spring-amqp 1.0.2.
06 окт '15 в 20:11
1
ответ
Подписание сообщения RabbitMQ
Я хочу использовать RabbitMQ для связи между несколькими приложениями, которые развернуты в разных сетях и обслуживаются разными людьми. Как получатель сообщения (потребитель) я хочу убедиться, что отправитель сообщения (производитель) - это тот, ке…
06 авг '18 в 09:02
1
ответ
Лучшая практика канала RabbitMQ
Я создаю API REST для отправки сообщения в RabbitMQ и пытался понять, как лучше всего создавать / закрывать каналы. Я использую RabbitMQ Java-клиент API. В настоящее время у меня есть класс RabbitMQPublisherConnection где я весной вставляю соединени…
13 мар '15 в 01:07
1
ответ
Получать запросы http в rabbitmq
API отправляет моему приложению сообщение через метод HTTP POST. Чтобы предотвратить потерю данных, когда мой контроллер выключен, я хочу использовать кролика. как получить http POST-запросы в rabbitmq? можно вообще?
07 июн '17 в 10:23
1
ответ
Как создать систему, которая будет прослушивать одну очередь кролика MQ, а затем выполнять серию заданий через кролика mq, а затем отвечать
Я хочу разработать такую систему, которая будет слушать на кролика MQ #queue1 это займет сообщение от кролика MQ В сообщении проверьте тип запроса это создаст пакет такого типа он отправит запрос на другой rabbit mq #Queue2 ждать ответа получить о…
21 июн '16 в 09:10
1
ответ
Как работать с rabbitTemplate receiveAndReply
Я только начал экспериментировать с Spring и rabbitMQ. Я хотел бы создать микросервисную инфраструктуру с кроликом и весной, я следую учебному пособию по загрузке Spring Но это очень упрощенно. Кроме того, я просматриваю документацию ( пружины, Крол…
02 июн '15 в 12:29