import { ReplaySubject, Subscription } from 'rxjs';
import { CallbackOptions, IMessageHandlerContext, PubsubSubscription } from './contracts/definitions';
import { IMessage } from './message';
import { SubscribeOptions } from './subscribe-options';
import { TracingService } from './tracing.service';
export declare class PubsubService implements IMessageHandlerContext {
    private tracingService;
    constructor(tracingService: TracingService);
    static ServiceName: string;
    private map;
    private subscriptions;
    subscribe({ messageType, callback, error, complete, }: SubscribeOptions): PubsubSubscription;
    publish<V extends IMessage = IMessage>(message: V): void;
    clearAllSubscriptions(): void;
    protected addSubscription(sub: Subscription): void;
    protected getSubject(messageType: string): ReplaySubject<CallbackOptions<IMessage>>;
    protected hasSubject(messageType: string): boolean;
    protected setNewSubject(messageType: string): void;
    private throwError;
}