Интеграция с Spring — передача данных между потоками

У меня есть специальный IntegrationFlow, настроенный как

@Bean
public IntegrationFlow setupRabbitFlow() {
    return IntegrationFlows.from(myInputChannel)     
            .handle((p, h) -> rabbitPublisher.publishToRabbit(p, h))
            .get();
}

и некоторый другой поток, который обрабатывает входящие данные из некоторых файлов XML, например. как показано здесь Опрос из файла с использованием Java DSL — ошибка компиляции при добавлении Files.inboundAdapter. К концу этого потока я хочу передать сообщение вышеупомянутой «раковине», отправляющей кроликов. Как мне это объявить?