Package energy.eddie.outbound.metric.connectors

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

Constructor	Description
AgnosticConnector()

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AgnosticConnector

public AgnosticConnector()

Method Details

getConnectionStatusMessageStream

public reactor.core.publisher.Flux<ConnectionStatusMessage> getConnectionStatusMessageStream()

setConnectionStatusMessageStream

public void setConnectionStatusMessageStream(reactor.core.publisher.Flux<ConnectionStatusMessage> connectionStatusMessageStream)

Description copied from interface: ConnectionStatusMessageOutboundConnector

Sets the stream of connection status messages to be sent to the EP app.

Specified by:

setConnectionStatusMessageStream in interface ConnectionStatusMessageOutboundConnector

Parameters:

connectionStatusMessageStream - stream of connection status messages