Реализация гарантированной асинхронной доставки сообщений

Как вы решаете проблему с остановкой si компонент(может быть service bus message)? почему не используете replay-channel? и на закуску почему все не обернули в chain?