Java+RabbitMQ, проверить сообщения в очереди на застой

Два дня сижу, не могу дойти до решения проблемы. У меня есть некая очередь. И email_sender. Который в определенной переодичностью в эту очередь кладет таски. Так вот, этих email_senderов может быть запущено любое количество. Мне нужно проверять на застой сообщений в очереди, мало ли по какой причине смс не уйдет, чтобы очередь не повисла. Я придумал вот такой алгоритм, теперь не знаю как его технически реализовать, может кто подскажет? Алгоритм верный, ментор говорит что правильно. Вот он: Создать отдельный модуль "Чекер". При запуске новой копии сендера записывать его адрес в этот модуль, для обработки нод.(как это реализовать, связь между сендером и чекером только через очередь) запись в коллекцию+ Чекер раз в 10 минут запрашивает коллекции с ИД меилтасков от сендеров(в коллекции записаны id тасков, которые нужно проверять) . Тот получает их от всех работающих и проводит проверку каждой коллекции.(как реализовать?) Дальше нужно достать из очереди смс и проверять на то, сколько они уже находятся в очереди, если больше часа, то удалить их оттуда, если нет, то положить обратно.

Вот и вся задача, но голову уже сломал над реализацией алгоритма.