Вопросы по теме 'spring-amqp'
Веб-приложение, использующее Spring AMQP, считается 1 клиентом?
Привет, мне интересно, создаю ли я веб-приложение, использующее Spring AMQP. Это единственный клиент AMQP webapp 1? Или каждый запрос, сделанный пользователем, который приводит к вызову AMQP, является клиентом, поэтому потенциально x количество...
281 просмотров
schedule
18.08.2022
RabbitMQ приостанавливает потребление очереди
Каков наилучший способ сохранить устойчивую очередь и ее привязки, но приостановить ее потребителей?
Вариант использования: я хотел бы «дать ему сбой» и прекратить обработку сообщений, если мы продолжаем получать кучу сообщений, с которыми мы не...
9237 просмотров
schedule
03.03.2023
Как заставить компилятор запретить мне использовать любые расширения RabbitMQ AMQP?
Я планирую использовать RabbitMQ в качестве реализации AMQP в своем проекте. Но я хотел бы ограничиться использованием только спецификации AMQP и не использовать какие-либо расширения RabbitMQ для AMQP . .
Есть ли способ оставить эту проверку...
63 просмотров
schedule
11.07.2023
Настройка Spring Integration QueueChannel для RabbitMQ
В настоящее время я использую Spring AMQP API для подключения к RabbitMQ. В основном в моем потребительском коде я читаю сообщения асинхронно и делаю массовую вставку в эластичный поиск. когда я делаю ack = AUTO, я получаю умеренную скорость 400-500...
483 просмотров
schedule
25.05.2022
Интеграция Spring и AMQP: как изящно обрабатывать исключения десериализации?
Я использую RabbitMQ и Spring Integration для обработки входящих сообщений JSON .
Соответствующая часть конфигурации выглядит примерно так:
<amqp:inbound-channel-adapter channel="incomingChannel" queue-names="..."...
3245 просмотров
schedule
21.09.2022
Возможно ли иметь приемник асинхронных сообщений в Spring AMQP, который обрабатывает несколько типов контента?
Я использую асинхронный приемник сообщений в Spring-AMQP для получения сообщений. В настоящее время обрабатываются только сообщения с содержимым JSON, но у меня есть требование также обрабатывать сообщения с содержимым XML. Моя текущая реализация...
1174 просмотров
schedule
03.10.2022
Контейнер Spring-AMQP RPC
Есть ли в spring-amqp контейнер, поддерживающий функцию ответа?
Я хочу создать RPC, например https://www.rabbitmq.com/tutorials/tutorial-six-java.html , но с использованием spring-amqp.
3047 просмотров
schedule
24.07.2022
Как вы можете создать RabbitMQ MessageListener, используя обмен темами с автоматически объявленными очередями?
Я использую RabbitMQ в Java, используя Spring AMQP. Я отправляю сообщения, используя тему обмена.
Я хочу использовать сообщения, используя автоматически объявленные очереди с указанным routingKey, и единственный способ, которым мне удалось...
2066 просмотров
schedule
27.10.2022
Шаблон запрос-ответ с использованием библиотеки Spring amqp
все. У меня есть HTTP API для отправки сообщений в брокере RabbitMQ, и мне нужно реализовать шаблон запрос-ответ, чтобы получать ответы от сервера. Так что я что-то вроде моста между клиентами и сервером. Я отправляю сообщения брокеру с...
4401 просмотров
schedule
14.02.2023
Spring RabbitTemplate не создает очередь недоставленных сообщений с TTL
Я использую spring-rabbit1.1 и RabbitMQ 3.3.1,
Моя весенняя конфигурация создаст любую очередь с помощью RabbitTemplate на Rabbit MQ, но если очередь была настроена с x-dead-letter-exchange и x-message-ttl, она просто создает очередь без TTL и...
3294 просмотров
schedule
08.10.2022
Как отправить basic.ack в очередь из обработчика сообщений в SimpleMessageListenerContainer
В API RabbitMQ, когда для канала auto-ack установлено значение false, мы можем использовать channel.basicAck(...) для отправки подтверждения обратно в очередь.
Весной у меня есть SimpleMessageListenerContainer , где я установил...
1335 просмотров
schedule
14.01.2023
Как выполнить тематическое потребление на RabbitMq?
Я новичок в RabbitMq и AMQP, но у меня есть некоторый опыт работы с ActiveMQ и JMS. Я пытаюсь опубликовать сообщение в теме (тема как тема в JMS) и получить это сообщение от нескольких слушателей. Например, я публикую сообщение о том, что в системе...
947 просмотров
schedule
12.12.2022
Сбалансированное соединение между Java-клиентом Spring AMQP и узлами кластера RabbitMQ?
Я хорошо знал, что Spring AMQP поддерживает аварийное переключение, но мой вопрос в том, как я могу сбалансировать нагрузку соединений между клиентской стороной и узлами кластера брокера RabbitMQ?
Мы будем благодарны за любой ответ.
С Уважением.
3499 просмотров
schedule
20.10.2022
apache qpid запрос-ответ
Я не нашел ни одного документа или примеров реализации запроса-ответа с использованием Apache qpid или даже AMQP в целом, поддерживается ли это и эффективное решение? Любая соответствующая информация будет принята с благодарностью.
Поскольку я...
749 просмотров
schedule
20.09.2022
Spring AMQP и Elasticsearch — объединение сообщений
У нас есть потребитель в некоторых очередях RabbitMQ, который читает сообщения, а затем индексирует эти данные в Elasticsearch. Реализация выполнена с использованием spring-amqp. Чтобы повысить нашу производительность, мы планируем агрегировать...
704 просмотров
schedule
23.06.2022
весна Amqp ReplyRequiredException
У меня есть запрос/ответ, реализованный с использованием интеграции Spring и amqp. Обработка запросов может занять много времени (в некоторых случаях это может занять даже час), по какой-то причине клиент выдает исключение -
Exception in thread...
1384 просмотров
schedule
06.01.2023
Spring-Amqp и Аполлон
Я использую библиотеку Spring-AMQP с RabbitMQ для производства. Я хотел написать несколько тестов, которые будут работать «чисто», и я думал об использовании встроенного брокера и издевательстве над ответами. Я знаю, что не могу внедрить Rabbit, но...
294 просмотров
schedule
12.07.2023
Получить аргументы и атрибуты очереди в RabbitMQ
В REST API RabbitMQ вы можете получить различную информацию о существующей очереди ( http://rabbit.example.com:15672/api/queues/ ):
{
"memory": 10888,
"messages": 0,
"messages_details": {
"rate": 0
},
"messages_ready":...
1030 просмотров
schedule
08.10.2022
Поддерживаемый AMQP канал публикации-подписки и преобразование сообщений
Мы используем <int-amqp:publish-subscribe-channel/> как своего рода шину событий в нашем сервисном приложении. Метод отправки, а также обработчик сообщений основаны на классе Message из spring-messaging (начиная с spring-integration 4.0...
523 просмотров
schedule
06.03.2023
Spring AMQP: CorrelationId изменяется между моментом отправки и получения сообщения
Пока я тестировал методы отправки и получения, которые я создал для своего проекта, я столкнулся со странной проблемой. Когда я отправляю определенное сообщение с использованием идентификатора корреляции, основанного на объекте UUID, принимающая...
392 просмотров
schedule
16.06.2023
