Class MessageProcessorBase<T extends DigitalTwinBase>

java.lang.Object
com.scaleoutsoftware.digitaltwin.core.MessageProcessorBase<T>
Type Parameters:
T - the type of the DigitalTwin
Direct Known Subclasses:
MessageProcessor

public abstract class MessageProcessorBase<T extends DigitalTwinBase> extends Object
Base class for the MessageProcessor to help with typing.
  • Constructor Details

    • MessageProcessorBase

      public MessageProcessorBase()
  • Method Details

    • processMessages

      public abstract ProcessingResult processMessages(ProcessingContext context, T twin, MessageFactory messageListFactory) throws Exception
      Helper method to ensure proper typing for the user methods.
      Parameters:
      context - the processing context
      twin - the real-time digital twin instance
      messageListFactory - the message list factory
      Returns:
      the implementing class's processing result
      Throws:
      Exception - if an exception occurs during processing