import { Collection, OptionalUnlessRequiredId } from 'mongodb';
import { BatchPublisher, BatchPublisherEvents, BatchPublisherOptions } from './BatchPublisher';
import { Consumer, ConsumerCallback, ConsumerEvents, ConsumerOptions } from './Consumer';
import { Publisher, PublisherOptions } from './Publisher';
import { Subscriber, SubscriberEvents, SubscriberOptions } from './Subscriber';
import { SubscriptionCallback, SubscriptionOptions } from './Subscription';
import { TypedEventEmitter } from './TypedEventEmitter';
import { WithOptionalObjectId } from './WithOptionalObjectId';
export interface MessageQueueOptions<TMessage extends WithOptionalObjectId> extends PublisherOptions, BatchPublisherOptions, SubscriberOptions<TMessage>, ConsumerOptions<TMessage> {
}
export interface MessageQueueEvents<TMessage extends WithOptionalObjectId> extends BatchPublisherEvents<TMessage>, SubscriberEvents<TMessage>, ConsumerEvents<TMessage> {
}
export declare class MessageQueue<TMessage extends WithOptionalObjectId> extends TypedEventEmitter<MessageQueueEvents<TMessage>> {
    readonly collection: Collection<TMessage>;
    protected options: MessageQueueOptions<TMessage>;
    protected publisher: Publisher<TMessage>;
    protected batchPublisher: BatchPublisher<TMessage>;
    protected subscriber: Subscriber<TMessage>;
    protected consumers: Consumer<TMessage>[];
    constructor(collection: Collection<TMessage>, options?: MessageQueueOptions<TMessage>);
    publish(message: OptionalUnlessRequiredId<TMessage>): Promise<import("mongodb").InferIdType<TMessage> | null>;
    publishBatched(message: OptionalUnlessRequiredId<TMessage>): void;
    subscribe<TSpecificMessage extends TMessage>(callback: SubscriptionCallback<TSpecificMessage>, options?: SubscriptionOptions<TSpecificMessage>): import("./Subscription").Subscription<TSpecificMessage>;
    consume<TSpecificMessage extends TMessage>(callback: ConsumerCallback<TSpecificMessage>, options?: ConsumerOptions<TSpecificMessage>): Consumer<TSpecificMessage>;
    drain(timeoutMs?: number): Promise<void>;
    close(): Promise<void>;
}