В моем текущем сценарии у меня есть источник файла от Alpakka, который должен генерировать события записи файла, которые я публикую в теме.На тему можно подписаться на другие сервисы для получения прочитанных событий.В большинстве примеров, которые я видел до сих пор, было внешнее событие, которое инициировало цепочку сервисов, которые нужно вызывать, однако в моем случае я хочу, чтобы система Alpakka запускалась сама по себе, чтобы читать файлы и публиковать события в теме.С чего бы мне начать это в моем сервисе?