import { Collection, Document, InsertOneOptions, OptionalUnlessRequiredId } from 'mongodb';
export interface PublisherOptions {
    insertOneOptions?: InsertOneOptions;
}
export declare class Publisher<TMessage extends Document> {
    protected collection: Collection<TMessage>;
    protected insertOneOptions: InsertOneOptions;
    protected closed: boolean;
    constructor(collection: Collection<TMessage>, options?: PublisherOptions);
    /**
     * Publishes the given message, returning the inserted message ID.
     * Ignores message duplicates, returning null in that case.
     * Can be used inside transactions (same options as MongoDB `insertOne`).
     */
    publish(message: OptionalUnlessRequiredId<TMessage>, options?: InsertOneOptions): Promise<import("mongodb").InferIdType<TMessage> | null>;
    close(): Promise<void>;
}