Class StarterCompletionMsgPublisher

Namespace

Tlabs.JobCntrl.Intern

Assembly

Tlabs.JobCntrl.dll

Default ContentRoot relative persistence path.

public class StarterCompletionMsgPublisher : IStarterCompletionPersister

Inheritance

object

StarterCompletionMsgPublisher

Implements

IStarterCompletionPersister

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

ConfigUtilsExtensions.ApplyConfigurators<T>(T, IConfiguration, string?)

Constructors

StarterCompletionMsgPublisher(IMessageBroker)

Ctor from msgBroker.

public StarterCompletionMsgPublisher(IMessageBroker msgBroker)

Parameters

msgBroker IMessageBroker

Fields

COMPLETION_SUBJECT

Published message subject.

public const string COMPLETION_SUBJECT = "JobCntrl.StarterCompletion"

Field Value

string

Methods

GetLastCompletionInfo(string, out string, out Encoding)

Returns a starters completion persistent info as a stream.

public Stream GetLastCompletionInfo(string starterName, out string contentType, out Encoding encoding)

Parameters

starterName string

starter instance name

contentType string

returned streams MIME content type

encoding Encoding

returned streams text encoding

Returns

Stream

A binray data stream for reading that must be disposed after usage ore null if no completion info available.

StoreCompletionInfo(IStarterCompletion)

Store starters completion info in a persistent storage.

public void StoreCompletionInfo(IStarterCompletion starterCompletion)

Parameters

starterCompletion IStarterCompletion

Events

CompletionInfoPersisted

Event fired when a starter completion info has been persisted.

public event Action<IStarterCompletionPersister, IStarterCompletion, object?>? CompletionInfoPersisted

Event Type

Action<IStarterCompletionPersister, IStarterCompletion, object>