API Reference

processEventOutboxCommands()

Creates a process event outbox commands.

Import

import { processEventOutboxCommands } from "@graphrefly/ts/orchestration/messaging";

Signature

function processEventOutboxCommands(
	graph: Graph,
	events: Node<ProcessEvent<TEvent>>,
	topic: string,
	opts: { readonly name?: string } = {},
): Node<MessageBusCommand>

Parameters

Parameter	Type	Description
`graph`	`Graph`	Graph that owns the created nodes or projector.
`events`	`Node<ProcessEvent<TEvent>>`	Event node or event collection to consume.
`topic`	`string`	topic value used by the helper.
`opts`	`{ readonly name?: string }`	Options that configure the helper.

Returns

The process event outbox commands result.

Example

import { processEventOutboxCommands } from "@graphrefly/ts/orchestration/messaging";

Source

packages/ts/src/orchestration/messaging.ts