import { Pausable } from '../../types';
import { DB } from '../db/db';
import { Message } from './message';
declare type BrokerSubscription = {
    queue: string;
    callback: (message: Message) => any;
};
export declare class Broker implements Pausable {
    db: DB;
    subscriptions: BrokerSubscription[];
    channels: Promise<void>[];
    closing: boolean;
    paused: boolean;
    constructor(db: DB);
    disconnect(): Promise<any>;
    publish(body: Record<string, any> | [Array<any>, Record<string, any>, Record<string, any>], exchange: string, routingKey: string, headers: Record<string, any>, properties: Record<string, any>): Promise<number>;
    pause(): Promise<void>;
    resume(): void;
    isPaused(): boolean;
    subscribe(queue: string, callback: (message: Message) => any): Promise<any[]>;
    private receiveFast;
    private receiveSlow;
    private receiveOneOnNextTick;
    private receiveOne;
}
export {};