Package energy.eddie.api.agnostic.outbound

Interface ConnectionStatusMessageOutboundConnector

All Known Implementing Classes:
AgnosticConnector, AgnosticConnector, AmqpOutbound, KafkaConnector
public interface ConnectionStatusMessageOutboundConnector
An outbound connector delivers data to the eligible party. All messages from the region connectors are passed on to the EP using their transport of choice, e.g. Kafka.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    setConnectionStatusMessageStream(reactor.core.publisher.Flux<ConnectionStatusMessage> connectionStatusMessageStream)
    Sets the stream of connection status messages to be sent to the EP app.

  • Method Details

    • setConnectionStatusMessageStream

      void setConnectionStatusMessageStream(reactor.core.publisher.Flux<ConnectionStatusMessage> connectionStatusMessageStream)
      Sets the stream of connection status messages to be sent to the EP app.
      Parameters:
      connectionStatusMessageStream - stream of connection status messages