@cloudamqp/amqp-client
    Preparing search index...

    Class AMQPRPCServer<P, C, KP, KC>

    An RPC server that consumes messages from a queue and replies to each caller.

    Uses the session's queue and subscribe machinery, so the consumer is automatically recovered after a reconnection.

    const session = await AMQPSession.connect("amqp://localhost")
    const server = await session.rpcServer("my_rpc_queue", async (msg) => {
      return `processed:${msg.bodyString()}`
    })
    // later…
    await session.stop()

    Type Parameters

    • P extends ParserMap = {}
    • C extends CoderMap = {}
    • KP extends keyof P & string = never
    • KC extends keyof C & string = never
    Index

    Methods

    close

    Methods

    • Cancel the consumer. The underlying queue remains declared.

      Returns Promise<void>

    Settings

    Member Visibility

    On This Page

    Methods