Вопросы по теме 'spring-amqp'
Как подтвердить сообщение через программу с использованием интеграции Spring AMQP / Spring
1) Сервер отправляет сообщение клиенту.
2) Адаптер входящего канала настроен на ожидание работы режима подтверждения "РУЧНОЙ" от потребителя.
3) Компонент «TaskBundlereceiver» реализует «ChannelAwareMessageListener», а в методе реализации я...
8401 просмотров
schedule
27.10.2021
RabbitMQ: отдельные партнеры потребителя и производителя при использовании только одного сервера очереди
мы собираемся использовать rabbitmq в нашем проекте, но столкнулись с проблемой, которую мы хотим отлаживать на наших машинах разработчика, поэтому ответное сообщение должно быть отправлено на машину, которая изначально отправила сообщение запроса....
518 просмотров
schedule
02.12.2021
Повторно ставьте сообщения AMQP кролика в хвост очереди после максимального количества попыток
В настоящее время я использую RabbitMQ с пружиной (spring-rabbit-1.2.0-RELEASE) со следующей конфигурацией:
<rabbit:template id="amqpTemplate" connection-factory="connectionFactory"/>
<!-- Asynchronous exchanges -->
<!-- Admin...
5628 просмотров
schedule
30.11.2021
Добавление нескольких контейнеров-слушателей с идентификаторами, похоже, не работает
У меня есть конфигурация rabbitMQ, в которой мне нужно иметь два отдельных контейнера-слушателя, каждый из которых имеет набор слушателей. Вот фрагмент из rabbitmq-context.xml:
<rabbit:listener-container
connection-factory="connectionFactory"...
1118 просмотров
schedule
08.11.2021
Как подтвердить сообщение с другого канала RabbitTemplate?
Предположим, у меня есть единственный экземпляр rabbitTemplate, и я вызываю rabbitTemplate.send （Message）, чтобы опубликовать сообщение на сервер RabbitMQ.
Вот что я хочу сделать: 1. с точки зрения издателя, как убедиться, что сообщение получено...
2161 просмотров
schedule
09.11.2021
Получение сообщения от rabbitmq, неспособного вернуть сообщение в многопоточной среде
Вот что делает мое приложение
1) Клиентское приложение Отправить сообщение запроса с correlationId на REQUEST_QUEUE_1 и ожидает ответного сообщения на RESPONSE_QUEUE_1, используя correlationId
2) Серверное приложение получает сообщение от...
339 просмотров
schedule
06.10.2021
Как я могу составить список очередей на обмене RabbitMQ с помощью Java?
У меня было два хоста, у каждого хоста есть какая-то очередь. Я хочу перечислить все очереди, объявленные другим узлом. На основе этих очередей я должен выполнить некоторую операцию.
Я не получил никакого метода, который перечислял бы все очереди...
2351 просмотров
schedule
14.09.2021
Spring AMQP обеспечивает порядок сообщений в многопоточной среде
RabbitMQ гарантирует порядок сообщений, если используется тот же канал публикации-> Обмен-> Очередь-> Канал приема. Похоже, Spring AMQP позволяет мне гарантировать все эти части, кроме канала публикации. Это приводит к тому, что сообщения выходят из...
664 просмотров
schedule
02.12.2021
Связь по шине сообщений Spring REST
Я ищу модуль Spring, который может помочь мне интегрировать веб-службы Spring REST с шиной сообщений (RabbitMQ). Веб-служба REST выступает в роли потребителя сообщений AMQP от клиента. Всякий раз, когда сообщения отправляются по шине, это сообщение...
2862 просмотров
schedule
02.10.2021
Необходимо проверить подход: Spring Integration + AMQP + Async
Я недавно исследовал Spring Integration и AMQP (RabbitMQ), так как мне нужно связать два приложения (промежуточное ПО и бэкэнд) с помощью асинхронного подхода, чтобы промежуточное ПО не блокировалось при получении клиентских вызовов.
Сначала я...
568 просмотров
schedule
20.11.2021
Spring AMQP 1.3.5 идентификатор корреляции
Кто-нибудь знает, почему Spring Integration (AMQP 1.3.5) требует, чтобы идентификатор корреляции был массивом байтов? AMQP-Client 3.3.5 Rabbit принимает строку в качестве идентификатора корреляции в классе AMQP.BasicProperties. Разве Spring в...
269 просмотров
schedule
27.11.2021
Аннотации Spring Amqp на основе
Я новичок в Spring AMQP и хочу использовать конфигурацию на основе аннотаций как для производителей, так и для потребителей, использующих последнюю версию Spring amqp 1.5.4,
Доступен ли для конфигурации какой-либо псевдо-код, который выполняет...
387 просмотров
schedule
07.11.2021
Как получить заказ для разных MessagePostProcessors в SimpleMessageListenerContainer
У меня есть несколько MessagePostProcessors в SpringAMQP, которые я установил с помощью SimpleMessageListenerContainer.setAfterReceivePostProcessors API, теперь мой запрос: вызываются ли эти MessagePostProcessors в указанном мной порядке.
Код...
125 просмотров
schedule
11.10.2021
исключение весеннего кролика в потребительском вопросе
У меня есть потребитель весеннего кролика:
public class SlackIdle1Consumer extends AbstractMessageConsumer {
@Override public void process(Message amqpMessage, Channel channel)
throws Exception {
/*very bad exception goes...
460 просмотров
schedule
07.09.2021
Потеряно ли сообщение, если при публикации сообщения в RabbitMQ возникает проблема, не имеющая отношения к сети?
Я использую Spring AMQP для публикации сообщений в RabbitMQ. Рассмотрим сценарий: 1. Клиент Java отправляет сообщение в MQ, используя amqpTemplate.convertAndSend () 2. Но RabbitMQ не работает ИЛИ возникла некоторая проблема, связанная с отсутствием...
291 просмотров
schedule
01.11.2021
`@ RabbitListener`` @ SendTo` Ответ не работает при возврате сообщения `org.springframework.messaging.Message‹? ›`
Я успешно использую метод, который возвращает мой бизнес-объект с аннотацией @RabbitListener .
Зарегистрированный bean-компонент Jackson2JsonMessageConverter с именем messageConverter отлично преобразует входящее сообщение JSON в ожидаемый тип...
425 просмотров
schedule
18.09.2021
Отправка сообщения в определенную очередь RabbitMQ с использованием SpringIntegration Java DSL
Я работаю над приложением Java, которое использует Spring Boot версии 2.0.4.RELEASE и RabbitMQ версии 3.7.7. Приложение кэширует все сообщения из RabbitMQ в базе данных Redis и должно повторно отправлять их, когда в RabbitMQ создается новая...
474 просмотров
schedule
02.12.2021
Spring AMQP: проверка конфигурации RabbitMQ
Я пытаюсь продемонстрировать использование механизма RabbitMQ Credit Flow в соответствии с упомянутым здесь блогом: https://www.rabbitmq.com/blog/2015/10/06/new-credit-flow-settings-on-rabbitmq-3-5-5/
В рамках своей демонстрации я хочу показать,...
136 просмотров
schedule
08.11.2021
Spring AMQP: динамическое создание нескольких очередей
У меня есть класс Spring @Configuration, который создает и регистрирует очереди RabbitMQ следующим образом:
@Amqp
@Configuration
public class AmqpConfiguration {
@Bean
ConnectionFactory connectionFactory() {
CachingConnectionFactory...
2274 просмотров
schedule
07.11.2021
SimpleMessageListenerContainer и IllegalArgumentException
Я получаю ошибку «IllegalArgumentException», пытаюсь сделать следующее:
Получите сообщение AMQP, которое заставляет меня остановить «SimpleMessageListenerContainer».
Сделайте запрос AMQP, используя механизм «прямого ответа».
Перезапустите...
696 просмотров
schedule
11.10.2021
