diff --git a/src/daemon/ticker.py b/src/daemon/ticker.py index a5d1655..8e05053 100644 --- a/src/daemon/ticker.py +++ b/src/daemon/ticker.py @@ -92,6 +92,13 @@ class Ticker: return self._running = True self._task = asyncio.create_task(self._loop()) + # 启动 InboxWatcher(即时事件监听) + if self.inbox_watcher: + try: + await self.inbox_watcher.start() + logger.info("InboxWatcher started") + except Exception as e: + logger.warning("InboxWatcher start failed: %s", e) logger.info("Ticker started (interval=%.1fs)", self.tick_interval) async def stop(self) -> None: