///
import { Connection } from "./connection";
export declare class Producer {
private connection;
private stream;
private publisherId;
private publisherRef;
constructor(params: {
connection: Connection;
stream: string;
publisherId: number;
publisherRef: string;
});
send(publishingId: bigint, message: Buffer): Promise;
getLastPublishingId(): Promise;
}