method IMessageBroker.respond
IMessageBroker.respond<TReq, TRes>(
topic: string,
handler: RequestHandler<TReq, TRes>,
): Promise<ISubscription>

Registers a responder for a request topic. The handler's resolved value is sent back to the requesting caller, correlated to the originating request.

Pass options.queue to load-balance requests across competing responders.

Type Parameters

TReq

The request payload type

TRes

The reply payload type

Parameters

topic: string

The request topic to respond on

Invoked per request; its result is returned to the caller

optional
options: SubscribeOptions

Consumer group behavior

Return Type

Promise<ISubscription>

The active subscription

Usage

import { type IMessageBroker } from "common/src/index.ts";