API Reference

orchestrationMessageCommand()

Creates an orchestration message command.

Import

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

Signature

function orchestrationMessageCommand(
	message: MessageBusMessage<TPayload>,
	delivery: MessageBusDelivery,
	policy?: OrchestrationMessagingPolicy<TPayload, TCommand>,
): ProcessCommand<TCommand> | undefined

Parameters

Parameter	Type	Description
`message`	`MessageBusMessage<TPayload>`	message value used by the helper.
`delivery`	`MessageBusDelivery`	delivery value used by the helper.
`policy`	`OrchestrationMessagingPolicy<TPayload, TCommand>`	Policy object used to admit, retry, or route work.

Returns

The orchestration message command result.

Example

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

Source

packages/ts/src/orchestration/messaging.ts