import { Configurations } from '../../../Configuration';
import { Observable } from 'rxjs';
import { LoginService } from '@serengeti/serengeti-common';
export declare class WebsocketExecuteService {
    private loginService;
    static defaultReconnectInterval: number;
    static defaultReconnectIntervalIncrement: number;
    static defaultMaxReconnectAttempt: number;
    clientId: string;
    connected: boolean;
    stompClient: any;
    endPoint: string;
    configurations: Configurations;
    config: any;
    private socket;
    stomp: any;
    private timer;
    private resolveConPromise;
    queuePromises: any[];
    private disconnectPromise;
    private resolveDisConPromise;
    status: string;
    private reconnectAttempt;
    constructor(loginService: LoginService, configurations: Configurations);
    /**
     * Configure
     */
    configure(config: any): void;
    reconnect(): void;
    connect(loginId: string): Observable<any>;
    close(): Promise<{}>;
    /**
     * Send
     */
    send(destination: string, body: any, headers?: Object): void;
    /**
     * Send
     */
    recv(body: any, headers?: any): void;
    /**
     * Try to establish connection to server
     */
    startConnect(): Promise<{}>;
    /**
     * Successfull connection to server
     */
    onConnect: (frame: any) => void;
    /**
     * Unsuccessfull connection to server
     */
    onError: (error: string) => void;
    /**
     * Subscribe
     */
    subscribe(destination: string, callback?: any, headers?: Object): any;
    /**
     * Unsubscribe
     */
    unsubscribe(subscription: any): void;
    /**
     * Disconnect stomp
     */
    disconnect(): Promise<{}>;
    /**
     * After specified subscription
     */
    after(name: string): Promise<{}>;
    /**
     * Done specified subscription
     */
    done(name: string): void;
    /**
     * Turn specified subscription on pending mode
     */
    pending(name: string): void;
    /**
     * Check name in queue
     */
    private nameCheck;
}