Module messaging 

Optional CQRS-over-messageBus recipe (D350/D351/D353).

Retained delivery is lowered to CQRS command facts. Ack commands are emitted only after a graph-visible accepted/rejected status or lowering issue exists; receiving a retained message is never itself an ack.

Structs

CqrsDeliveredCommand

CqrsDeliveredCommand data container.

CqrsMessageAckOptions

CqrsMessageAckOptions data container.

CqrsMessagingPolicy

CqrsMessagingPolicy data container.

CqrsMessagingRecipeBundle

CqrsMessagingRecipeBundle data container.

CqrsMessagingRecipeOptions

CqrsMessagingRecipeOptions data container.

MessageBusDelivery

MessageBusDelivery data container.

Functions

cqrs_event_outbox_commands

Creates or computes cqrs_event_outbox_commands.

cqrs_message_ack_commands

Creates or computes cqrs_message_ack_commands.

cqrs_messaging_recipe

Creates or computes cqrs_messaging_recipe.

Type Aliases

CqrsMessageCommandFn

CqrsMessageCommandFn type alias.