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