Latest
interface AmqpSink
import { type AmqpSink } from "https://dotland.deno.dev/x/amqp@v0.24.0/src/amqp_multiplexer.ts";

Methods

send<T extends number, U extends number>(
channel: number,
classId: T,
methodId: U,
args: ExtractMethodArgs<T, U>,
): Promise<void>
publish(
channel: number,
publishArgs: BasicPublishArgs,
data: Uint8Array,
): Promise<void>