Вопросы по теме 'spring-amqp'

Spring Rabbit не позволяет переопределять значения по умолчанию в конфигурации фабрики кеширования соединений: выпуск 1.1.4
Я пробую приложение Spring amqp для отправки данных JSON в виде сообщений потребителю (написано на Ruby). Я получаю ошибки сброса подключения при любых настройках, которые я пытаюсь ПРИМЕЧАНИЕ. Я удалил гостя по умолчанию и добавил...
5960 просмотров
schedule 12.10.2023

Проектирование и масштабирование очереди RabbitMQ
В моем приложении есть очередь, которая потенциально может стать очень большой. Что, если я обнаружу, что на моей машине больше нет места? Как я могу разделить свою очередь на несколько машин? Может быть, философия RabbitMQ отличается, и мне...
6537 просмотров

Как остановить экземпляры SimpleMessageListenerContainer?
У нас есть несколько хостов, которые рассылают сообщения через Exchange. Для этих нескольких хостов я создал экземпляр SimpleMessageListenerContainer, который привязывается к очереди и хосту. Я зарегистрировал прослушиватель для контейнера. При...
697 просмотров
schedule 25.12.2022

Spring AMQP v1.4.2 - проблема повторного подключения кролика при сбое сети
Я тестирую следующий сценарий в Spring AMQP v1.4.2, и он не может повторно подключиться после сбоя сети: Запустите приложение spring, которое асинхронно потребляет сообщения, используя rabbit: listener-container и rabbit: connection-factory...
14387 просмотров
schedule 26.07.2023

Обработка ошибок SimpleMessageListenerContainer
Я использую SimpleMessageListenerContainer в качестве основы для удаленного взаимодействия через AMQP. Все идет гладко при условии, что брокер RabbitMQ доступен при запуске процесса. Однако, если по какой-либо причине он недоступен (сеть не...
3171 просмотров
schedule 06.07.2023

Исключения Spring AMQP
Это мой первый вопрос в stackoverflow. Я работаю в проекте, который включает Spring AMQP. Для разработки я нашел этот учебник: Пример Spring AMQP Когда я запускаю класс ListenerContainer, я получаю следующее исключение: Вызвано:...
476 просмотров
schedule 18.04.2023

Публикация транзакций Spring-AMQP без исключения
Я пытаюсь использовать канал Transactionnal RabbitMQ с Spring-AMQP, но я хочу фактически проглотить исключения, чтобы регистрировать их и иметь возможность их восстанавливать. Использование channelTranscted = true заставляет канал также...
502 просмотров

Фоновые задачи в Spring (AMQP)
Мне нужно выполнить трудоемкую и подверженную ошибкам задачу (например, вызов конечной точки SOAP, которая инициирует доставку SMS) всякий раз, когда вызывается данная конечная точка моего REST API, но я бы предпочел не заставлять своих пользователей...
124 просмотров
schedule 19.02.2024

Учебник Spring RabbitMQ приводит к ошибке отказа в подключении
Я опытный программист на Java и впервые пробую Spring Rabbit MQ. Я следовал руководству по обмену сообщениями RabbitMQ точно , используя Maven. http://spring.io/guides/gs/messaging-rabbitmq/ Я работаю на CentOS в качестве учетной записи...
13897 просмотров
schedule 11.03.2023

RabbitMQ: создание динамических очередей в Direct Exchange
Я новичок в RabbitMQ, я только что просмотрел документы Rabbitmq (маршрутизация). Я совсем запутался между Exchange и ключами маршрутизации. Мое требование: я хочу динамически создавать несколько очередей. Пожалуйста, обратитесь к приведенной ниже...
1572 просмотров

Spring AMQP Project с 2 очередями
Я работаю над проектом, который включает в себя 2 очереди и несколько слушателей, взаимодействующих с ними. Поток: Новый HTTP-запрос приходит на сервер, затем он преобразуется в объект, который будет сообщением Это сообщение должно быть...
8686 просмотров
schedule 16.07.2023

Spring пакетная интеграция удаленного фрагментирования с использованием AMQP (Rabbit)
Я пытаюсь реализовать Remote Chunking , как описано здесь http://docs.spring.io/spring-batch/trunk/reference/html/springBatchIntegration.html#externalizing-batch-process-execution . Моя простая мастерская работа: <job id="job"...
1339 просмотров

@RabbitListener — определение очередей из свойств
Можно ли использовать свойство, разделенное запятыми, для определения очередей для прослушивания? Цель состоит в том, чтобы иметь возможность изменять имена очередей и количество очередей без изменения кода. Я определил очереди в моем...
6071 просмотров
schedule 30.08.2023

RabbitListener выполняет задачу, когда в очереди нет сообщения
мы используем @RabbitListener для прослушивания очереди, и когда есть сообщения, мы их обрабатываем. Однако я хочу выполнить некоторую отчетную задачу, когда очередь пуста, это происходит, когда наше приложение только что обработало тонны сообщений в...
466 просмотров
schedule 19.08.2023

Spring RabbitTemplate - как получить опубликованное сообщение для NACK в режиме подтверждения издателя
У меня есть веб-приложение, которое публикует сообщения на RabbitQueue с помощью spring. Я включил подтверждение издателя и включил возврат, и я использую шаблон spring rabbit: template. Это моя конфигурация: <rabbit:template...
1527 просмотров
schedule 09.03.2024

Spring Rabbitlistner перестает слушать очередь, используя синтаксис аннотаций
Мы с коллегой работаем над приложением, использующим Spring, которому необходимо получить сообщение из очереди RabbitMQ. Идея состоит в том, чтобы сделать это с помощью (обычно превосходной) системы пружинных аннотаций, чтобы упростить понимание...
4571 просмотров

Тестовая среда в Spring Amqp
Есть ли какая-нибудь тестовая среда вокруг Spring Amqp, я изучил множество областей, но не смог найти ни одной.
577 просмотров
schedule 05.04.2023

Spring AMQP принимает меры по тайм-ауту сообщения
Я использую Spring AMQP с асинхронным обменом сообщениями. Моя модель предполагает, что есть два приложения A и B, как производители, так и потребители. A отправляет запрос на задание B и начинает прослушивание. B прослушивает запрос на...
582 просмотров
schedule 19.06.2022

Как запретить Spring AMQP блокировать незапакованные сообщения?
У меня есть _ 1_ аннотированный метод, для которого Spring AMQP блокируется после возврата из метода. Базовая ссылка _ 2_ использует _ 3_ . Я пока не хочу подтверждать сообщение в методе слушателя. Есть ли способ избежать блока Spring AMQP в...
968 просмотров
schedule 19.11.2022

Как изящно закрыть канал и соединение, когда длина очереди достигает нуля?
Мы используем библиотеку Spring AMQP для приема сообщений из очередей в RabbitMQ. Наш издатель создает переменное количество сообщений по известному расписанию, поэтому мы думаем о том, чтобы запускать потребителей по расписанию и останавливаться,...
654 просмотров
schedule 04.03.2022