Package energy.eddie.outbound.rest.connectors

Class AgnosticConnector

java.lang.Object

energy.eddie.outbound.rest.connectors.AgnosticConnector

All Implemented Interfaces:

ConnectionStatusMessageOutboundConnector, OpaqueEnvelopeOutboundConnector, RawDataOutboundConnector, AutoCloseable

@Component
public class AgnosticConnector
extends Object
implements ConnectionStatusMessageOutboundConnector, RawDataOutboundConnector, OpaqueEnvelopeOutboundConnector, AutoCloseable

Constructor Summary

Constructors

Constructor	Description
AgnosticConnector()

Method Summary

Modifier and Type	Method	Description
void	close()
reactor.core.publisher.Flux<ConnectionStatusMessage>	getConnectionStatusMessageStream()
reactor.core.publisher.Flux<OpaqueEnvelope>	getOpaqueEnvelopes()	A flux of OpaqueEnvelopes, which provide an opaque envelopes with any payload for a certain time period.
reactor.core.publisher.Flux<RawDataMessage>	getRawDataMessageStream()
void	publish(OpaqueEnvelope envelope)
void	setConnectionStatusMessageStream(reactor.core.publisher.Flux<ConnectionStatusMessage> connectionStatusMessageStream)	Sets the stream of connection status messages to be sent to the EP app.
void	setRawDataStream(reactor.core.publisher.Flux<RawDataMessage> rawDataStream)	Sets a Flux that can be subscribed to, to emit raw data messages to the eligible party.

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()

getRawDataMessageStream

public reactor.core.publisher.Flux<RawDataMessage> getRawDataMessageStream()

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

setRawDataStream

public void setRawDataStream(reactor.core.publisher.Flux<RawDataMessage> rawDataStream)

Description copied from interface: RawDataOutboundConnector

Sets a Flux that can be subscribed to, to emit raw data messages to the eligible party.

Specified by:

setRawDataStream in interface RawDataOutboundConnector

Parameters:

rawDataStream - flux containing raw data messages

getOpaqueEnvelopes

public reactor.core.publisher.Flux<OpaqueEnvelope> getOpaqueEnvelopes()

Description copied from interface: OpaqueEnvelopeOutboundConnector

A flux of OpaqueEnvelopes, which provide an opaque envelopes with any payload for a certain time period.

Specified by:

getOpaqueEnvelopes in interface OpaqueEnvelopeOutboundConnector

Returns:

A flux of opaque envelopes to be sent to the region-connector.

publish

public void publish(OpaqueEnvelope envelope)

close

public void close()

Specified by:

close in interface AutoCloseable