import { AmqpChannel } from "https://deno.land/x/amqp@v0.23.1/mod.ts";
Methods
ack(args: BasicAckArgs)
bindExchange(args: ExchangeBindArgs): Promise<ExchangeBindOk>
bindQueue(args: QueueBindArgs): Promise<QueueBindOk>
cancel(args: BasicCancelArgs): Promise<BasicCancelOk>
close()
closed()
consume(args: BasicConsumeArgs, handler: BasicDeliverHandler): Promise<BasicConsumeOk>
declareExchange(args: ExchangeDeclareArgs): Promise<ExchangeDeclareOk>
declareQueue(args: QueueDeclareArgs): Promise<QueueDeclareOk>
deleteExchange(args: ExchangeDeleteArgs): Promise<ExchangeDeleteOk>
deleteQueue(args: QueueDeleteArgs): Promise<QueueDeleteOk>
nack(args: BasicNackArgs)
off(event: "deliver", handler: BasicDeliverHandler): void
off(event: "return", handler: BasicReturnHandler): void
on(event: "deliver", handler: BasicDeliverHandler): void
on(event: "return", handler: BasicReturnHandler): void
publish(): Promise<void>
purgeQueue(args: QueuePurgeArgs): Promise<QueuePurgeOk>
qos(args: BasicQosArgs): Promise<BasicQosOk>
reject(args: BasicRejectArgs)
unbindExchange(args: ExchangeUnbindArgs): Promise<ExchangeUnbindOk>
unbindQueue(args: QueueUnbindArgs): Promise<QueueUnbindOk>