diff --git a/src/entities/InterchangeSystem.ts b/src/entities/InterchangeSystem.ts index f9877b9..662cfe8 100644 --- a/src/entities/InterchangeSystem.ts +++ b/src/entities/InterchangeSystem.ts @@ -111,6 +111,7 @@ export class InterchangeSystem { let etaRepository: BaseRedisETARepository; if (args.useSelfUpdatingEtas) { etaRepository = new RedisSelfUpdatingETARepository(shuttleRepository); + (etaRepository as RedisSelfUpdatingETARepository).startListeningForUpdates(); } else { etaRepository = new RedisExternalSourceETARepository(); }