API Reference

cqrsMessageCommand()

Creates a CQRS message command.

Import

import { cqrsMessageCommand } from "@graphrefly/ts/cqrs/messaging";

Signature

function cqrsMessageCommand(
	message: MessageBusMessage<TPayload>,
	delivery: MessageBusDelivery,
	policy?: CqrsMessagingPolicy<TPayload, TCommand>,
): CqrsCommand<TCommand> | undefined

Parameters

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

Returns

The CQRS message command result.

Example

import { cqrsMessageCommand } from "@graphrefly/ts/cqrs/messaging";

Source

packages/ts/src/cqrs/messaging.ts