Вопросы по теме 'spring-amqp'
Создание сообщения amqp с использованием python и использование того же сообщения с использованием java
Я пытаюсь создать сообщение amqp из python и использовать это же сообщение из java/spring.
Вот мой код producer (python):
import pika, sys, pickle
sys.path.append("trc/suivi/amqp")
from Person import Person
connection =...
1605 просмотров
schedule
01.06.2022
Уведомление об отключении/повторном подключении брокера AMQP с помощью Spring-AMQP/RabbitMQ
Одна из приятных особенностей Spring-AMQP заключается в том, что он, по-видимому, реализует необходимую логику для повторного подключения приложения Spring к брокеру сообщений, когда брокер выходит из строя и снова включается.
То, что я ищу, - это...
2887 просмотров
schedule
27.12.2022
Распределенная пакетная обработка с помощью Spring Batch и AMQP
Я хочу распределить обработку больших партий. Идея состоит в том, чтобы использовать Spring Batch для запуска группы потребителей AMQP в облаке, а затем для загрузки дешевых задач (например, идентификаторов элементов) и отправки их на биржу AMQP....
3118 просмотров
schedule
09.05.2022
Можем ли мы одновременно запускать несколько экземпляров одного и того же задания с разными параметрами, используя пакетное разделение Spring и rabbitmq
Я реализовал свои пакетные задания, используя весеннее пакетное разделение и используя rabbitmq в качестве промежуточного программного обеспечения.
Я изучил документацию и сослался на эти модульные тесты...
2765 просмотров
schedule
06.01.2023
Как мне обработать сообщение после истечения времени ожидания возврата RabbitTemplate?
У меня есть шаблон кролика, настроенный для синхронного возврата. Он отправляет сообщение в очередь входа, которая обрабатывает и возвращает токен. В настоящее время я устанавливаю тайм-аут на определенное значение, которого я обычно не ожидаю....
582 просмотров
schedule
14.05.2023
Ошибка при обновлении Spring-AMQP с 1.2.0 до 1.3.0
Наше приложение построено и работает на: spring.version = 3.2.8.RELEASE spring.amqp.version = 1.2.0.RELEASE rabbitmq.version = 3.1.3 (клиент) Версия сервера RabbitMQ — 3.1.5.
Мы хотели обновить сервер rabbitmq с 3.1.5 до 3.3.5, и нам это...
309 просмотров
schedule
27.11.2022
Последовательность доставки сообщений с истекшим сроком действия RabbitMQ
Мы создаем решение, в котором мы публикуем сообщение в очередь ожидания. По истечении срока жизни сообщения помещаются в основную очередь для повторной обработки.
Мы настраиваем значение счетчика, чтобы сообщения проверялись на x no. раз для...
1314 просмотров
schedule
19.05.2023
Отправка сообщения Rabbit AMQPTemplate под управлением диспетчера транзакций EJB
Я использую spring amqp для размещения сообщения в очереди Rabbit внутри EJB (сеансовый компонент без сохранения состояния).
Когда исключение выбрасывается из контейнера EJB, обновления данных откатываются, можно ли каким-либо образом заставить...
365 просмотров
schedule
12.11.2023
Отправка файлов через RabbitMQ
Стоит ли отправлять файлы размером около 1 Мб через RabbitMQ? Я хочу отправить сообщение в формате json с двоичными полями, соответствующими файлам.
И как это правильно сделать с помощью spring-amqp? Просто опубликовав объект со следующим...
7213 просмотров
schedule
09.02.2023
Spring-AMQP и прямой ответ
Я нашел это «расширение» RabbitMQ, указанное здесь: http://www.rabbitmq.com/direct-reply-to.html , я установил "replyQueue" RabbitTemplate с помощью amq.rabbitmq.reply-to . Я попробовал это с уже функционирующим вызовом RPC, и он функционировал,...
3233 просмотров
schedule
26.02.2023
rabbitmq с spring amqp - сообщения застряли в случае исключения AmqpException
Я бросаю исключение AmqpException внутри своего потребителя. Я ожидаю, что сообщение вернется обратно в очередь в порядке FIFO и будет повторно обработано когда-нибудь в будущем.
Кажется, что Spring AMQP не возвращает сообщение в очередь. Но...
3618 просмотров
schedule
13.11.2022
Поддерживает ли Spring AMQP федерацию rabbitmq?
Я знаю, что Spring поддерживает кластеризацию rabbitmq через атрибут «адреса» в <rabbit:connection-factory> . Хотя обеспечивает ли он поддержку федеративных RabbitMQ, и если да, то как?
175 просмотров
schedule
28.12.2022
Основан ли подсчет сообщений Spring-AMQP на JVM?
Я копался в документации rabbitmq, и мне кажется, что rabbitmq не обрабатывает счетчик повторной доставки сообщений. Если бы мне пришлось вручную отправлять сообщения ACK / NACK, мне нужно было бы либо сохранить счетчик повторов в памяти (например,...
817 просмотров
schedule
31.01.2024
Проблема с настройкой возможности повторной попытки с помощью Spring AMQP с использованием шаблона повторной попытки
Я пытаюсь настроить возможность повторной попытки в своем проекте Spring Integration, где я пытаюсь подключиться к серверам Rabbit, следуя подробностям, представленным здесь в этом статья раздел 3.3.1. Но похоже, что политика повторных попыток не...
3260 просмотров
schedule
14.07.2023
Spring AMQP: MessageListener не получает сообщений
В настоящее время я создаю настраиваемую библиотеку поверх проекта Spring AMQP. Я подошел к тому моменту, когда я хочу реализовать прослушиватель сообщений, чтобы иметь возможность получать сообщения асинхронно. После дальнейшего изучения...
1871 просмотров
schedule
06.11.2022
Переименовать имя очереди перед инициализацией в Spring amqp
У меня есть особенное требование в spring amqp для переименования обмена и очереди во время выполнения перед загрузкой его свойств из beans.xml Например, имя моей очереди определено в beans.xml как test
<bean id="test"...
524 просмотров
schedule
04.12.2023
Spring AMQP возвращает обратный вызов против повторного обратного вызова
Я хочу сделать свое приложение устойчивым к проблемам с подключением, которые могут возникнуть при отправке сообщений в rabbitmq. Я хочу получить все неотправленные сообщения, сохранить их и отправить позже, когда станет доступным rabbitmq.
Глядя...
1993 просмотров
schedule
26.01.2023
Получение java.lang.NoClassDefFoundError: com/rabbitmq/client/impl/LongString при получении сообщений из ответа Q
Я использую spring-integration-amqp 4.1.4 с rabbitmq amqp-client 3.5.3. Сообщения доставляются нормально, но при получении ответных сообщений возникает следующее исключение.
org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer...
6528 просмотров
schedule
14.12.2022
Сохранение MDC с запросом/ответом Spring AMQP
У меня есть две службы, A и B, которые обмениваются данными через Удаленное взаимодействие Spring с помощью AMQP . A предоставляет REST API и заполняет MDC (сопоставленный диагностический контекст) UUID.randomUUID() (из Filter ) при каждом...
586 просмотров
schedule
07.01.2023
Как дать ответ на основании подтверждения издателя
У меня есть веб-служба, которая принимает объекты, отправляет уведомление через AMQP и возвращает ответ JSON запрашивающей стороне. Каждый запрос выполняется в одном потоке, и я пытаюсь реализовать подтверждения издателя, и я борюсь с тем, как мне...
291 просмотров
schedule
12.09.2022
