interface Subscription {
    id: string;
    topic: string;
    callback: (message: {
        body: string;
    }) => void;
    subscription?: () => void;
}
export default class WssConnection {
    url: string;
    endpoint: string;
    subscriptions: Array<Subscription>;
    socket: {
        (url: string, _reserved?: any, options?: SockJS.Options | undefined): WebSocket;
        new (url: string, _reserved?: any, options?: SockJS.Options | undefined): WebSocket;
        prototype: WebSocket;
        CONNECTING: SockJS.CONNECTING;
        OPEN: SockJS.OPEN;
        CLOSING: SockJS.CLOSING;
        CLOSED: SockJS.CLOSED;
    } | undefined;
    client: any;
    queuedMessages: Array<any>;
    processingMsg: boolean;
    wssBroken: boolean;
    /**
     *
     * @param {String} url url of the wss
     * @param {String} endpoint of the wss
     * @param {Map<String, Function>} topics list of topics and associated callback
     */
    constructor(url: string, endpoint: string);
    processQueuedMessages(): Promise<void>;
    connect(): Promise<void>;
    connectionErrorReconnect(): Promise<void>;
    connectionSuccess(): void;
    subscribe(topic: string, callback: (message: {
        body: string;
    }) => any): void;
    unsubscribe(topic: string): void;
    disconnect(): void;
}
export {};