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