Информация об очереди Hazelcast

В настоящее время я пишу распределенную систему с использованием hazelcast. У меня есть несколько вопросов по поводу очередей, реализованных с помощью hazelcast.

1. Как лучше всего обрабатывать данные из очереди? В настоящее время у меня есть потоки на каждом «узле», считывающие из очереди блокировки, обрабатывающей данные. Это правильно, или есть какой-то класс, о котором я не знаю, который заботится об этом, например, JMS или messageListener?
2. Я вижу, что есть настройка времени жизни в секундах, которая удалит запись из очереди после истечения срока ее действия. У меня вопрос ... есть ли способ обнаружить удаление просроченного элемента из очереди? Я знаю, что есть Listeners, но это не помогает, так как запускается на всех «узлах», а не только на одном. Я ищу способ выполнения кода для каждого просроченного сообщения (аналогично очереди недоставленных сообщений).

Мы будем очень благодарны за любой вклад или совет по этому поводу.

Спасибо