Package energy.eddie.api.agnostic

Interface ConnectionStatusMessageProvider

All Superinterfaces:
AutoCloseable
All Known Implementing Classes:
ConnectionStatusMessageHandler, DeConnectionStatusMessageProvider, DocumentStreams
public interface ConnectionStatusMessageProvider extends AutoCloseable
Used to extend a RegionConnector by making a Flux of ConnectionStatusMessages available.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
    Emit a complete signal on the Flow in this method.
    reactor.core.publisher.Flux<ConnectionStatusMessage>
    getConnectionStatusMessageStream()
    Data stream of all connection status updates created by this region connector.

  • Method Details

    • getConnectionStatusMessageStream

      reactor.core.publisher.Flux<ConnectionStatusMessage> getConnectionStatusMessageStream()
      Data stream of all connection status updates created by this region connector.
      Returns:
      connection status message stream

    • close

      void close() throws Exception
      Emit a complete signal on the Flow in this method.
      Specified by:
      close in interface AutoCloseable
      Throws:
      Exception