Jobs Worker Messaging And Execution Model

Purpose

This functional area defines how background work is received and executed.

Main Capabilities

• MassTransit consumer execution
• configurable transport support for background processing
• in-memory execution for local development and RabbitMQ-backed execution for brokered deployments
• retry-enabled background processing
• shared consumer hosting for enrichment, retention, and governance-related workloads

Functional Value

This area gives the platform a reliable asynchronous processing model across components.

Long-Running Consumers

A broker enforces a maximum time a consumer may hold a delivery without acknowledging it. When that limit is exceeded the broker withdraws the delivery and requeues it, regardless of whether the consumer is still working.

This ceiling applies to the total duration of a unit of work, not to any individual operation inside it. A consumer that makes many outbound calls can satisfy every per-call timeout and still breach the limit in aggregate. When introducing or lengthening a long-running consumer, size the broker's limit against the worst-case total duration of the work, and give the workload its own means of detecting and recovering from an interrupted run rather than relying on the broker alone.

The semantic enrichment consumer is the platform's reference implementation of this pattern; see Jobs Worker Semantic Enrichment Processing.