spring-amqp

0зной

1ответ

Spring Кролик: режим Признайте = Ручной с RetryTemplate не удаляет сообщение из очереди

Я делаю следующие шаги: MessageListener получает сообщение из очереди Q1 Сверяет сообщение Если проверка сбой, вызовите channel.basicReject() и переместите его в очередь мертвых букв. Остается, скажем

2зной

2ответ

Spring AMQP - отправитель и получающие сообщения

У меня возникла проблема с получением сообщения от RabbitMQ. Я посылаю сообщение, как показано ниже HashMap<Object, Object> senderMap=new HashMap<>(); senderMap.put("STATUS", "SUCCESS");

3зной

1ответ

RabbitMQ - Реализация регекса Exchange Exchange

Предположим, если у меня есть ключ привязки как «a.b. *», то я могу использовать ключи маршрутизации как a.b.1, a.b.2, a.b.3, a.b.4 и так далее. Я хочу очередь, чтобы принимать сообщения от всех этих

1зной

1ответ

Spring AMQP: [RabbitTemplate] Hystrix fallback не запускается, когда выполняется RabbitTemplate ReturnCallback.

Я использую hystrix для обработки сценариев фолк-бэка, когда мои сообщения не доставляются на сервер RabbitMQ. Мой резервный вызов вызывается, когда сервер RabbitMQ недоступен (по мере того, как выдае

0зной

1ответ

Как получить заказ для разных MessagePostProcessors в SimpleMessageListenerContainer

У меня есть несколько MessagePostProcessors в SpringAMQP, которые я установил с помощью API SimpleMessageListenerContainer.setAfterReceivePostProcessors, теперь мой запрос заключается в том, что эти M

0зной

1ответ

Отрицательное подтверждение для очереди RabbitMQ для повторной очереди сообщения с использованием Spring AMQP

У меня есть приложение, которое использует Spring AMQP для потребления и создания сообщений для другого приложения. У меня есть сценарий, в котором произошло какое-то исключение, мне нужно снова поста

1зной

1ответ

Spring AMQP Сообщение Задержка

Мой вопроса очень похож на этот: Why is there a delay in Spring AMQP Message dispatching from a filled Queue? Я могу видеть задержку между двумя вызовами моего сообщением слушателя, даже если очередь