cqrsWorkQueueDispositionCommand()

Creates a CQRS work queue disposition command.

Import

import { cqrsWorkQueueDispositionCommand } from "@graphrefly/ts/cqrs/work-queue";

Signature

function cqrsWorkQueueDispositionCommand(
  attempt: CqrsWorkQueueAttempt<TCommand>,
  outcome: CqrsWorkQueueOutcome,
  policy?: CqrsWorkQueuePolicy,
): WorkQueueCommand<CqrsQueuedCommandPayload<TCommand>>

Parameters

Parameter	Type	Description
attempt	CqrsWorkQueueAttempt<TCommand>	attempt value used by the helper.
outcome	CqrsWorkQueueOutcome	Outcome value to record or index.
policy	CqrsWorkQueuePolicy	Policy object used to admit, retry, or route work.

Returns

The CQRS work queue disposition command result.

Example

import { cqrsWorkQueueDispositionCommand } from "@graphrefly/ts/cqrs/work-queue";

Source

packages/ts/src/cqrs/work-queue.ts