Skip to main content
Module

x/amqp/src/amqp_multiplexer.ts>AmqpSource

lenkan/deno-amqp
Very Popular
Latest
interface AmqpSource
import { type AmqpSource } from "https://deno.land/x/amqp@v0.24.0/src/amqp_multiplexer.ts";

Methods

subscribe<T extends number, U extends number>(
channel: number,
classId: T,
methodId: U,
handler: (args: ExtractMethod<T, U>) => void,
): () => void
receive<T extends number, U extends number>(
channel: number,
classId: T,
methodId: U,
): Promise<ExtractMethod<T, U>>
receiveContent<T extends number>(channel: number, classId: T): Promise<[ExtractProps<T>, Uint8Array]>