/// <reference types="node" />
export = MqttProtocol;
/**
 * @class MqttProtocol
 */
declare class MqttProtocol extends Protocol {
    constructor();
    aedes: any;
    server: net.Server;
    connections: Map<any, any>;
    connectionsById: Map<any, any>;
    logger: import("../../../kuzzle/Logger").Logger;
    publishCallback: (error: any) => void;
    init(entryPoint: any): Promise<boolean>;
    broadcast(data: any): void;
    disconnect(connectionId: any, message?: string): void;
    joinChannel(): void;
    leaveChannel(): void;
    notify(data: any): void;
    /**
     * @param {Client} client
     */
    onConnection(client: Client): void;
    /**
     * @param {Client} client
     */
    onDisconnection(client: Client): void;
    /**
     * @param packet
     * @param client
     */
    onMessage(packet: any, client: any): void;
    _respond(client: any, response: any): void;
    _respondError(client: any, error: any): void;
    _authorizePublish(client: any, packet: any, callback: any): void;
    _authorizeSubscribe(client: any, sub: any, callback: any): void;
}
import Protocol = require("./protocol");
import net = require("net");