import { EdaManager } from "../eda-manager.js"; import { EventSubMgr } from "../event-sub-mgr.js"; import { ServiceLocator } from "@nivinjoseph/n-ject"; import { Logger } from "@nivinjoseph/n-log"; import { Redis } from "ioredis"; import { EdaEvent } from "../eda-event.js"; export declare class RedisEventSubMgr implements EventSubMgr { private readonly _client; private readonly _logger; private readonly _brokers; private _monitor; private _isDisposing; private _isDisposed; private _disposePromise; private _manager; private _isConsuming; constructor(redisClient: Redis, logger: Logger); initialize(manager: EdaManager): void; consume(): Promise; dispose(): Promise; protected onEventReceived(scope: ServiceLocator, topic: string, event: EdaEvent): void; } //# sourceMappingURL=redis-event-sub-mgr.d.ts.map