import { IEventBusManager, Integr8Config } from '../types';
import { Logger } from '../utils/logger';
export declare class EventBusManager implements IEventBusManager {
    private config;
    private workerId;
    private subscribers;
    private logger;
    constructor(config: Integr8Config, workerId: string, logger: Logger);
    publish(topic: string, data: any): Promise<void>;
    subscribe(topic: string, handler: (data: any) => void): Promise<void>;
    unsubscribe(topic: string, handler: (data: any) => void): Promise<void>;
    private getWorkerSpecificTopic;
}
//# sourceMappingURL=event-bus-manager.d.ts.map