Constructor JobQueuePass

Namespace

MailFathom.Application.Jobs.Execution

Assembly

MailFathom.Application.dll

JobQueuePass(IJobStore, JobHandlerRegistry, IJobAttemptRunner, JobConcurrencyGate, JobExecutionSettings)

Initializes the pass from the queue it claims out of and the bounds it claims and runs under.

public JobQueuePass(IJobStore store, JobHandlerRegistry handlers, IJobAttemptRunner attemptRunner, JobConcurrencyGate concurrency, JobExecutionSettings settings)

Parameters

store IJobStore

Claims the batch this pass runs.

handlers JobHandlerRegistry

Answers which job types this process can run.

attemptRunner IJobAttemptRunner

Runs one claimed job, isolated from the jobs running beside it, and records its outcome.

concurrency JobConcurrencyGate

Decides how many of the batch run at once, in total and per job type.

settings JobExecutionSettings

The batch size and the lease each claimed job is held under.

Exceptions

ArgumentNullException

Thrown when a collaborator is null.