Package energy.eddie.outbound.rest.connectors

Class AgnosticConnector

java.lang.Object

energy.eddie.outbound.rest.connectors.AgnosticConnector

All Implemented Interfaces:

OpaqueEnvelopeOutboundConnector, AutoCloseable

@Component
public class AgnosticConnector
extends Object
implements 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)
void	setRawDataStream(reactor.core.publisher.Flux<RawDataMessage> rawDataStream)

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)

setRawDataStream

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

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