12345678910111213141516171819202122232425262728293031323334353637383940414243
import { AmqpConnection } from "./amqp_connection.ts";import { AmqpSocket } from "./amqp_socket.ts";import { AmqpConnectOptions, parseOptions } from "./amqp_connect_options.ts";
export type { AmqpConnectOptions };
export async function connect(): Promise<AmqpConnection>;export async function connect(  options?: AmqpConnectOptions,): Promise<AmqpConnection>;export async function connect(uri?: string): Promise<AmqpConnection>;export async function connect(  optionsOrUrl?: AmqpConnectOptions | string,): Promise<AmqpConnection> {  const {    hostname,    port,    username,    password,    heartbeatInterval,    loglevel,    vhost,    frameMax,    tls,  } = parseOptions(optionsOrUrl);
  const conn = tls ? await Deno.connectTls({ port, hostname }) : await Deno.connect({ port, hostname });  const socket = new AmqpSocket(conn);
  const connection = new AmqpConnection(socket, {    username,    password,    heartbeatInterval,    frameMax,    loglevel,    vhost,  });
  await connection.open();
  return connection;}