Skip to main content
Module

x/amqp/mod.ts>AmqpConnection

lenkan/deno-amqp
Very Popular
Go to Latest
class AmqpConnection
implements AmqpConnection
import { AmqpConnection } from "https://deno.land/x/amqp@v0.23.1/mod.ts";

Constructors

new
AmqpConnection(socket: AmqpSocket, options: AmqpConnectionOptions)

Methods

close()

Gracefully close this connection.

closed()

Returns a promise that is settled when this connection is closed.

If the connection is gracefully closed, the promise will resolve.

If the connection is unexpectedly closed by the server or from an error, the promise will reject with the reason.

open()

Open this connection.

openChannel(): Promise<AmqpChannel>

Creates and opens a new channel