method InMemoryBroker.prototype.publishWithHeaders
InMemoryBroker.prototype.publishWithHeaders<T>(
topic: string,
message: T,
headers: Readonly<Record<string, string>>
): Promise<void>

Publishes a message with framework-owned transport headers. Resolves on dispatch hand-off (see publish); each invoked handler's promise is RETAINED and its rejection routed to the failure path below — never dropped, never unhandled. @internal

Type Parameters

Parameters

topic: string
message: T
headers: Readonly<Record<string, string>>

Return Type

Promise<void>

Usage

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