method RedisStreamsBroker.prototype.publish
Since 0.1.0
RedisStreamsBroker.prototype.publish<T>(
topic: string,
message: T
): Promise<void>

Publishes a message to a topic (Redis stream).

Type Parameters

T

The message payload type

Parameters

topic: string

The topic (stream name) to publish to

message: T

The message payload

Return Type

Promise<void>

Resolves when published

Usage

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