Class MessageProcessor<TDigitalTwin>

Namespace

Scaleout.Modules.DigitalTwin.Abstractions

Assembly

Scaleout.Modules.DigitalTwin.Abstractions.dll

Abstract base class that must be subclassed to implement the message processor which processes incoming messages for a digital twin object.

public abstract class MessageProcessor<TDigitalTwin> : MessageProcessor where TDigitalTwin : DigitalTwinBase<TDigitalTwin>

Type Parameters

TDigitalTwin

User-defined type for a digital twin object.

Inheritance

object

MessageProcessor

MessageProcessor<TDigitalTwin>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

ProcessMessageAsync(ProcessingContext<TDigitalTwin>, TDigitalTwin, byte[])

This method is called by ScaleOut StreamServer to pass new messages to the specified digital twin object.

public abstract Task<ProcessingResult> ProcessMessageAsync(ProcessingContext<TDigitalTwin> context, TDigitalTwin digitalTwin, byte[] msgBytes)

Parameters

context ProcessingContext<TDigitalTwin>

The digital twin message processing context.

digitalTwin TDigitalTwin

The target digital twin object.

msgBytes byte[]

Message data to be processed.

Returns

Task<ProcessingResult>

DoUpdate when the digital twin object and the list of processed messages need to be updated and NoUpdate when no updates are needed.