Class TypedTransportDispatcher

Namespace

JobFlow.Core.Jobs.Dispatch

Assembly

JobFlow.Core.dll

Dispatcher that ensures the Document<T> and WorkRequest<T> are of the appropriate type.

[ApplicationService(ManagerLifetime.Singleton, AsSelf = true, IncludeInterfaces = false)]
public class TypedTransportDispatcher : BaseJobDispatcher, IJobDispatcher

Inheritance

object

BaseJobDispatcher

TypedTransportDispatcher

Implements

IJobDispatcher

Inherited Members

BaseJobDispatcher._mapper

BaseJobDispatcher._flowDefinitionConfiguration

BaseJobDispatcher.DispatchAsync(Job, JsonElement?, IDocument)

Extension Methods

AutoMapperExtensions.Map<T>(T, IMapper)

Constructors

TypedTransportDispatcher(IDocumentConverter, ITransportManager, IMapper, IOptions<FlowDefinitionConfiguration>)

public TypedTransportDispatcher(IDocumentConverter documentConverter, ITransportManager transportManager, IMapper mapper, IOptions<FlowDefinitionConfiguration> flowDefinitionConfiguration)

Parameters

documentConverter IDocumentConverter

transportManager ITransportManager

mapper IMapper

flowDefinitionConfiguration IOptions<FlowDefinitionConfiguration>

Methods

DispatchAsync(JobModel, IDocument, FlowDefinition)

Abstract method for dispatching the job and document.

protected override Task DispatchAsync(JobModel jobModel, IDocument processedDoc, FlowDefinition flowDefinition)

Parameters

jobModel JobModel

processedDoc IDocument

flowDefinition FlowDefinition

Returns

Task

ProcessDocument(IDocument)

Process incoming document (to convert it, for instance).

protected override IDocument ProcessDocument(IDocument document)

Parameters

document IDocument

Returns

IDocument