Interface Handler<T extends Message>

All Known Implementing Classes:
OfflineEdgeHandler, SumStateHandler

public interface Handler<T extends Message>
  • Method Details

    • stop

      void stop()
      Stop the Handler.
    • send

      void send(ZonedDateTime sentAt, List<T> messages)
      Send the messages.
      Parameters:
      sentAt - TimeStamp at with sending was initiated
      messages - which to send
    • getGeneric

      Class<T> getGeneric()
      Return generic type of handler as Class object.
      Returns:
      GenericType of handler
    • getEventHandler

      Consumer<EventReader> getEventHandler(String eventTopic)
      Handle given event.
      Parameters:
      eventTopic - to handle
      Returns:
      Consumer to be scheduled in executor