import { MqttClientConfig } from "./mqtt";
import * as mqtt from "mqtt";
export default class MQTTMessagePool {
    client?: mqtt.MqttClient;
    subscribers: Map<string, (topic: string, message: Buffer) => void>;
    errors: Map<string, (error: Error) => void>;
    connect(brokerURI: string, config: MqttClientConfig): Promise<void>;
    subscribe(filter: string | string[], callback: (topic: string, message: Buffer) => void, error: (error: Error) => void): Promise<void>;
    unsubscribe(filter: string | string[]): Promise<void>;
    publish(topic: string, message: Buffer, options?: mqtt.IClientPublishOptions): Promise<void>;
    end(): Promise<void>;
}