Constructor MailChunkingPass

Namespace

MailFathom.Application.Emails.Chunking

Assembly

MailFathom.Application.dll

MailChunkingPass(IStoredEmailChunkingStore, IEmailEmbeddingBacklog, IDerivedWorkGateTelemetry, OptimisticConcurrencyRetryPolicy)

Initializes the pass from the state it walks and the backlog it hands messages to.

public MailChunkingPass(IStoredEmailChunkingStore chunkingStore, IEmailEmbeddingBacklog embeddingBacklog, IDerivedWorkGateTelemetry gateTelemetry, OptimisticConcurrencyRetryPolicy commitPolicy)

Parameters

chunkingStore IStoredEmailChunkingStore

Reads what is awaiting the cut and performs it.

embeddingBacklog IEmailEmbeddingBacklog

Takes each cut message on to the embedding worker.

gateTelemetry IDerivedWorkGateTelemetry

Reports which of the classification gate's answers let each message through.

commitPolicy OptimisticConcurrencyRetryPolicy

Commits one message's passages, retrying a conflict with a competing writer.

Exceptions

ArgumentNullException

Thrown when any argument is null.