Class BaseJobDispatcher

Namespace

JobFlow.Core.Jobs.Dispatch

Assembly

JobFlow.Core.dll

Abstract base class for Job dispatchers.

public abstract class BaseJobDispatcher : IJobDispatcher

Inheritance

object

BaseJobDispatcher

Implements

IJobDispatcher

Derived

BasicTransportDispatcher

TypedTransportDispatcher

Extension Methods

JsonExtentions.ToJObject<T>(T)

JsonExtentions.ToJsonBytes<T>(T)

JsonExtentions.ToJsonString<T>(T)

AutoMapperExtensions.Map<T>(T, IMapper)

Constructors

BaseJobDispatcher(IMapper, IOptions<FlowDefinitionConfiguration>)

protected BaseJobDispatcher(IMapper mapper, IOptions<FlowDefinitionConfiguration> flowDefinitionConfiguration)

Parameters

mapper IMapper

flowDefinitionConfiguration IOptions<FlowDefinitionConfiguration>

Fields

_flowDefinitionConfiguration

protected readonly IOptions<FlowDefinitionConfiguration> _flowDefinitionConfiguration

Field Value

IOptions<FlowDefinitionConfiguration>

_mapper

protected readonly IMapper _mapper

Field Value

IMapper

Methods

DispatchAsync(Job, JObject, IDocument)

public Task DispatchAsync(Job job, JObject data, IDocument document)

Parameters

job Job

data JObject

document IDocument

Returns

Task

DispatchAsync(JobModel, IDocument, FlowDefinition)

Abstract method for dispatching the job and document.

protected abstract 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 virtual IDocument ProcessDocument(IDocument document)

Parameters

document IDocument

Returns

IDocument