С помощью RabbitMQ Admin (v3) я попытался создать очередь, которая будет отправлять недоставленные сообщения на обмен по умолчанию, с ключом маршрутизации «MyErrorRoutingKey», к которому привязана очередь ошибок. Так что в интерфейсе...

Я пишу фрагмент кода, который позволит нам: Просмотр списка всех недоставленных сообщений, существующих в теме служебной шины Azure (просмотр) Исправьте и отправьте обратно в Тему Удалите их из очереди недоставленных писем при повторной...

При использовании модели Pub / Sub с NSB следующие два сценария, по-видимому, вызывают заполнение очереди недоставленных сообщений, что в конечном итоге приводит к ошибке «Недостаточно ресурсов». 1) Публикация типа события, у которого нет...

Мы реализовали отложенную обработку сообщений с 2 ​​очередями и x-dead-letter-exchange / x-message-ttl, где после тайм-аута сообщения в queue1 оно перейдет в queue2. Теперь можно настроить RabbitMQ так, чтобы, если во время обработки сообщений из...

Вот что у нас здесь: Обмен темами DLE , который задуман как обмен недоставленными сообщениями Тематическая биржа E , которая является «основной» биржей Несколько очередей ( EQ1 , ..., EQn ) привязаны к E (и инициализированы с помощью...

Я искал в Интернете и на GitHub готовую программу просмотра мертвых писем для служебной шины Azure. Это сделано для того, чтобы наша команда DevOps могла отслеживать, просматривать и сообщать о любых мертвых письмах для каждой подписки по каждой теме...

Я пытаюсь реализовать очередь недоставленных сообщений с помощью ActiveMQ. К сожалению, документация на этом конце довольно расплывчата по некоторым аспектам, и я не могу все правильно настроить. У меня настроены следующие компоненты: @Bean...

У меня есть приложение, которое отправляет сообщения в очередь служебной шины Azure. У меня также есть другое приложение, которое читает сообщения из этой очереди и обрабатывает затем отправляет обработанное сообщение в тему. Я вижу, что большинство...

С помощью Spring и RabbitMQ я создал два обмена темами x и dlx и две очереди q и dlq . q привязан к x , а dlq к dlx . dlx настроен как обмен недоставленными сообщениями для q . Когда сообщение в q отклоняется (с удалением из...

У меня есть проект, который в настоящее время использует Spring Cloud Streams и RabbitMQ. Я реализовал логику на основе документации . Смотри ниже: @Component public class ReRouteDlq { private static final String ORIGINAL_QUEUE =...

Хорошо, я относительно новичок в сервисной шине. Работаем над проектом, в котором мы используем сервисную шину Azure для постановки сообщений в очередь. Наша архитектура примерно выглядит следующим образом: Идея состоит в том, что в нашей...

У меня есть конфигурация: @Configuration @EnableKafka public class ConsumerConfig { final DlqErrorHandler dlqErrorHandler; public ConsumerConfig(DlqErrorHandler dlqErrorHandler) { this.dlqErrorHandler = dlqErrorHandler; }...

Я настроил маршрутизацию недоставленных сообщений с моей очередью, чтобы повторно ставить в очередь отклоненные сообщения с задержкой в ​​несколько секунд, предотвращая временные ошибки потребителей, которые могут засорить очередь. Я настроил это...