Class AgnosticConnector
java.lang.Object
energy.eddie.outbound.metric.connectors.AgnosticConnector
- All Implemented Interfaces:
ConnectionStatusMessageOutboundConnector
@Component
public class AgnosticConnector
extends Object
implements ConnectionStatusMessageOutboundConnector
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<ConnectionStatusMessage> voidsetConnectionStatusMessageStream(reactor.core.publisher.Flux<ConnectionStatusMessage> connectionStatusMessageStream) Sets the stream of connection status messages to be sent to the EP app.
-
Constructor Details
-
AgnosticConnector
public AgnosticConnector()
-
-
Method Details
-
getConnectionStatusMessageStream
-
setConnectionStatusMessageStream
public void setConnectionStatusMessageStream(reactor.core.publisher.Flux<ConnectionStatusMessage> connectionStatusMessageStream) Description copied from interface:ConnectionStatusMessageOutboundConnectorSets the stream of connection status messages to be sent to the EP app.- Specified by:
setConnectionStatusMessageStreamin interfaceConnectionStatusMessageOutboundConnector- Parameters:
connectionStatusMessageStream- stream of connection status messages
-