import { AmqpChannel } from "https://deno.land/x/amqp@v0.24.0/src/amqp_channel.ts";
Constructors
new
AmqpChannel(channelNumber: number, mux: AmqpMultiplexer)Properties
receiveContent: <T extends number>(classId: T) => Promise<[ExtractProps<T>, Uint8Array]>
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>