Обработка исключений с помощью Spring Cloud Stream и RabbitMq

У меня проблема с поиском информации об обработке исключений в Spring Cloud Stream. Я знаю, что есть errorChannel, который должен обрабатывать исключения, но я понятия не имею, как его использовать. Может ли кто-нибудь дать мне образцы? В настоящее время, когда я отправляю событие в мой приемник (@StreamListener(target = Sink.SAMPLE)) и во время обработки будет происходить MessageHandlingException, я получаю только журнал, и нет никакого механизма для уведомления моего источника. Я пробовал использовать @ControllerAdvice in my sink application и перехватить исключение в классическом стиле Spring MVC, но не думаю, что это должно быть так.