method RedisStreamsBroker.prototype.requestWithHeaders
RedisStreamsBroker.prototype.requestWithHeaders<TReq, TRes>(
topic: string,
message: TReq,
headers: Readonly<Record<string, string>>,
options?: RequestOptions
): Promise<TRes>

Sends request-reply traffic with framework-owned headers. @internal

Type Parameters

TReq
TRes

Parameters

topic: string
message: TReq
headers: Readonly<Record<string, string>>
optional
options: RequestOptions

Return Type

Promise<TRes>

Usage

import { RedisStreamsBroker } from "messaging-plugin/src/index.ts";