Package energy.eddie.outbound.rest.connectors

Class AgnosticConnector

java.lang.Object

energy.eddie.outbound.rest.connectors.AgnosticConnector

All Implemented Interfaces:

OpaqueEnvelopeOutboundConnector, PermissionCommandOutboundConnector, AutoCloseable

@Component
public class AgnosticConnector
extends Object
implements PermissionCommandOutboundConnector, 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>	getForwardedOpaqueEnvelopeStream()
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<PermissionCommand>	getPermissionCommands()	A flux of PermissionCommands, to route the permission commands to the correct region-connector.
reactor.core.publisher.Flux<RawDataMessage>	getRawDataMessageStream()
void	publish(OpaqueEnvelope envelope)
void	publish(PermissionCommand permissionCommand)
void	setConnectionStatusMessageStream(reactor.core.publisher.Flux<ConnectionStatusMessage> connectionStatusMessageStream)
void	setForwardedOpaqueEnvelopeStream(reactor.core.publisher.Flux<OpaqueEnvelope> forwardedOpaqueEnvelopeStream)
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()

setConnectionStatusMessageStream

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

getRawDataMessageStream

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

setRawDataStream

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

getForwardedOpaqueEnvelopeStream

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

setForwardedOpaqueEnvelopeStream

public void setForwardedOpaqueEnvelopeStream(reactor.core.publisher.Flux<OpaqueEnvelope> forwardedOpaqueEnvelopeStream)

getPermissionCommands

public reactor.core.publisher.Flux<PermissionCommand> getPermissionCommands()

Description copied from interface: PermissionCommandOutboundConnector

A flux of PermissionCommands, to route the permission commands to the correct region-connector.

Specified by:

getPermissionCommands in interface PermissionCommandOutboundConnector

Returns:

Contains the regionConnectorId, the permissionID, the timestamp and additional properties per command action

publish

public void publish(PermissionCommand permissionCommand)

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