Пытаюсь построить следующую схему (см. картинку). Есть очередь, в которую попадают сообщения (в теле сообщения 2 параметра – код и статус). Далее данные из этого сообщения через JavaCompute Node (JC_SetStatus) инсертятся в некую оракловую таблицу. В конце если все ОК отправляется письмо с уведомлением о том что все хорошо, если же при инсерте произошла ошибка (например, сервер оракла не доступен), то сообщение отправляется в очередь ошибок (MQOutput) и опять же идет извещение о ошибке.
Теперь хочется сделать следующее, что бы через определенные интервалы времени, сообщения из очереди ошибок пытались все таки обработаться. В данной теме я новичок, поэтому сделал следующим образом.
Поставил TimeoutNotification Node который каждые 15 минут запускает MQGet и извлекает сообщение из очереди ошибок. Далее сообщение идет по стандартной ветке. Но возникла проблема MQGet извлекает из очереди только одно сообщение, т.е. когда проблема ищезнет , то из очереди ошибок сообщения будут извлекаться раз в 15 минут, а нужно что бы обработались все сразу. Вопрос как это сделать? Подскажите правильную реализацию.

Все таки мне не совсем понятно... как отправить сообщение в очередь ошибок это еще более менее понятно, но не ясно как потом эти сообщения обрабатывать после исправления ошибки. dead letter handler - можно немножко подробней об этом? Зачем этот хендлер и как он работает?