import { AMQPBaseClient } from "./amqp-base-client.js"; import type { AMQPTlsOptions } from "./amqp-tls-options.js"; import type { Logger } from "./types.js"; import * as net from "net"; /** * AMQP 0-9-1 client over TCP socket. */ export declare class AMQPClient extends AMQPBaseClient { socket?: net.Socket | undefined; readonly tls: boolean; readonly host: string; readonly port: number; readonly tlsOptions: AMQPTlsOptions | undefined; private readonly insecure; private framePos; private frameSize; private readonly frameBuffer; /** * @param url - uri to the server, example: amqp://user:passwd@localhost:5672/vhost * @param tlsOptions - optional TLS options * @param logger - optional logger instance, defaults to null (no logging) */ constructor(url: string, tlsOptions?: AMQPTlsOptions, logger?: Logger | null); connect(): Promise; private connectSocket; private onRead; /** * @ignore * @param bytes to send * @return fulfilled when the data is enqueued */ send(bytes: Uint8Array): Promise; protected closeSocket(): void; } //# sourceMappingURL=amqp-socket-client.d.ts.map