Class MessageProcessor<TDigitalTwin, TMessage>

Namespace

Scaleout.Streaming.DigitalTwin.Core

Assembly

ScaleOut.Streaming.DigitalTwin.Core.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, TMessage> : MessageProcessor where TDigitalTwin : class

Type Parameters

TDigitalTwin

User-defined type for a digital twin object.

TMessage

User-defined type for incoming messages.

Inheritance

object

MessageProcessor

MessageProcessor<TDigitalTwin, TMessage>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

ProcessMessages(ProcessingContext, TDigitalTwin, IEnumerable<TMessage>)

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

public abstract ProcessingResult ProcessMessages(ProcessingContext context, TDigitalTwin digitalTwin, IEnumerable<TMessage> newMessages)

Parameters

context ProcessingContext

The digital twin message processing context.

digitalTwin TDigitalTwin

The target digital twin object.

newMessages IEnumerable<TMessage>

New messages to process.

Returns

ProcessingResult

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