2015-12-15 11 views
1

Как можно повторить попытку вручную в RabbitMQ после того, как сообщение было помещено в очередь мертвых букв?RabbitMQ Manual Retry

Предоставляет ли RabbitMQ пользовательский интерфейс, через который вы можете это сделать? Я предполагаю, что консоль RabbitMQ не предоставляет вам эту возможность.

ответ

1

Интерфейс управления Rabbit MQ позволил бы вам сделать это грубо, вы можете зайти в очередь для очереди, «получить» сообщение, затем скопировать содержимое. Перейдите в очередь, в которую вы хотите повторить сообщение, и «опубликуйте» его непосредственно в этой очереди.

В качестве альтернативы вы можете включить плавающий плагин, который позволяет перемещать сообщения из одной очереди в другую. Плагин управления RabbitMQ Management содержит инструкции о том, как это сделать.

+0

Первый вариант не может быть предложен в качестве решения для клиента. Чтобы попробовать второй вариант, я включил плагин для лопаты, но, похоже, это делается автоматически. Требование состоит в том, что администратор должен иметь возможность проверять сообщение и помещать его обратно в очередь через пользовательский интерфейс. Должна быть автоматически выбрана очередь, в которую идет сообщение. – user180908

+0

Это, по сути, настраиваемая функциональность. Сценарий почти рабочего процесса/пользователя. Может быть, напишите небольшое приложение для этого? Не было бы слишком тяжело/занимать слишком много времени. –

0

Вы можете написать потребитель/производитель, используя ряд различных клиентских библиотек. Для python популярной библиотекой является pika (https://pypi.python.org/pypi/pika).

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

+0

Снова я не смотрю на то, что вы автоматически загружаете и публикуете сообщения. Администратору необходимо вручную проверить сообщение и вручную запустить повторную попытку. – user180908

+0

Вы можете вручную просмотреть сообщение, и сценарий будет потреблять/публиковать одно сообщение за раз. Затем запустите скрипт для каждого просматриваемого сообщения. –