Здесь на самом деле нет модели, потому что концепция, вероятно, слишком специфична для конкретной ситуации.
Короче, однако, вам нужно будет определить staleness и проверять его каждый раз, когда вы читаете сообщение из очереди.
Согласно комментарию @ Space_C0wb0y к OP, для этого может использоваться простой таймер истечения срока действия или другой таймер истечения, или это может быть какая-то другая более сложная проверка в соответствующей точке линии.
Реально, однако, это невозможно реализовать как отдельный шаг в цепочке, который помещает сообщение обратно в очередь, поскольку в вашем сценарии задержка может произойти после того, как проверки были выполнены.
Итак, чтобы повторить, любые проверки такого рода должны проходить в самый последний момент, на фактическом этапе обработки, после чтения из очереди.