Вопрос по DeadLetter

[Ezergil]

@VadimZhogalsky @vzhzhzh

Вопрос

Вот есть такая штука, как DeadLetter. Как я понимаю, обычно туда попадают сообщения, которые не смогли обработаться (например, какое-то количество раз)

В этой реализации туда попадают сообщения, на которых нет подписчиков

И когда подписчик добавляется - он начинает процессить DeadLetters
Как я понял - даже если подписчик добавится много позже - он тоже обработает эти сообщения, даже если это не предполагается (например, это совершенно новая логика и ей не нужно процессить старые сообщения)
Логично, что в этом случае коллекцию можно почистить/удалить, но может(и должно ли) это обрабатываться программно в этом проекте?

[ondator]

Hi @Ezergil!

DeadLetter channel in this case should be correct, refer to https://www.enterpriseintegrationpatterns.com/patterns/messaging/DeadLetterChannel.html
On the other hand you right, there are special channel for invalid messages(https://www.enterpriseintegrationpatterns.com/patterns/messaging/InvalidMessageChannel.html), but it's not implemented now for MongoQueue

In the case of changing message handling logic before handling dead letter channel I belive that you can solve this with message versioning. Unfortunately we can specify version programmatically, but you can send to us a PR to support versioning on the Handler side(I suppose you just should add an Version field to message Headers and process it on the Handler side)