Class MessageSubscription

Namespace

Tlabs.JobCntrl.Model.Intern.Starter

Assembly

Tlabs.JobCntrl.dll

Starter that activates on published messages.

public class MessageSubscription : BaseStarter, IStarter, IModel, IDisposable

Inheritance

object

BaseModel

BaseStarter

MessageSubscription

Implements

IStarter

IModel

IDisposable

Inherited Members

BaseStarter.RUN_PROPERTY_PREFIX

BaseStarter.isEnabled

BaseStarter.Initialize(string, string, IReadOnlyDictionary<string, object>)

BaseStarter.DoActivate(IReadOnlyDictionary<string, object>)

BaseStarter.Enabled

BaseStarter.Activate

BaseModel.InitBase(string, string, IReadOnlyDictionary<string, object>)

BaseModel.PropertyString(string)

BaseModel.PropertyString(string, string)

BaseModel.PropertyInt(string, int)

BaseModel.PropertyBool(string, bool)

BaseModel.PropertyEnum(string, Enum)

BaseModel.Dispose()

BaseModel.Name

BaseModel.Description

BaseModel.Properties

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?)

Remarks

The starter subscribes on a message subject specified by the PROP_MSG_SUBJECT config. property. The published message gets passed as run-properties.

If a buffer time (millisec.) was specified, multiple messages published within that buffer time are buffered into one single activation.

Constructors

MessageSubscription(IMessageBroker)

Ctor from msgBroker.

public MessageSubscription(IMessageBroker msgBroker)

Parameters

msgBroker IMessageBroker

Fields

PROP_BUFFER

Name of a property that specifies a optional buffer time in miliseconds.

public const string PROP_BUFFER = "Buffer-Ms"

Field Value

string

PROP_MSG_SUBJECT

Name of a property that specifies the message subject.

public const string PROP_MSG_SUBJECT = "Message-Subject"

Field Value

string

PROP_RET_RESULT

Name of a property that enables returning a result.

public const string PROP_RET_RESULT = "Return-Result"

Field Value

string

Remarks

If this property is set to trueAutomationJobMessage must be published with PublishRequest<TRet>(string, object, int)!!

Methods

ChangeEnabledState(bool)

Changes the enabled state of the starter according to enabled.

protected override void ChangeEnabledState(bool enabled)

Parameters

enabled bool

Dispose(bool)

Dispose managed resources on disposing == true.

protected override void Dispose(bool disposing)

Parameters

disposing bool

InternalInit()

Internal starter initialization.

protected override IStarter InternalInit()

Returns

IStarter