Package com.scaleoutsoftware.digitaltwin.abstractions

Class MessageProcessor<T extends DigitalTwinBase<T>>

java.lang.Object

com.scaleoutsoftware.digitaltwin.abstractions.MessageProcessor<T>

Type Parameters:

T - the real type of the DigitalTwinBase

public abstract class MessageProcessor<T extends DigitalTwinBase<T>>
extends Object

Processes messages for a real-time digital twin.

Constructor Summary

Constructors

Constructor	Description
MessageProcessor()	Default constructor.

Method Summary

Modifier and Type	Method	Description
abstract ProcessingResult	processMessage(ProcessingContext<T> context, T stateObject, byte[] incomingMessage)	Processes a set of incoming messages and determines whether to update the real-time digital twin.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MessageProcessor

public MessageProcessor()

Default constructor.

Method Details

processMessage

public abstract ProcessingResult processMessage(ProcessingContext<T> context,
 T stateObject,
 byte[] incomingMessage)
                                         throws Exception

Processes a set of incoming messages and determines whether to update the real-time digital twin.

Parameters:

context - optional context for processing.

stateObject - the state object.

incomingMessage - the incoming message.

Returns:

processing results for updating the state object.

Throws:

Exception - if an exception occurs during processing