import { Subscription as NatsSubscription } from 'nats';
import { LiveFeedSubscriptionType, Subscription, SubscriptionCallback } from '../types';
export declare class LiveFeed {
    private connection;
    private subscriptions;
    private subscriptionCallbacks;
    private retryCount;
    connect(): Promise<void>;
    disconnect(): Promise<void>;
    subscribe(type: LiveFeedSubscriptionType, exchangeToken?: number | string): Promise<Subscription | undefined>;
    unsubscribe(subscription: NatsSubscription, topic: string): void;
    consume(subscription: NatsSubscription, callback: SubscriptionCallback): Promise<void>;
    private reconnect;
}