Package energy.eddie.outbound.amqp

Class AmqpOutbound

java.lang.Object

energy.eddie.outbound.amqp.AmqpOutbound

All Implemented Interfaces:

ConnectionStatusMessageOutboundConnector, RawDataOutboundConnector, AccountingPointEnvelopeOutboundConnector, PermissionMarketDocumentOutboundConnector, ValidatedHistoricalDataEnvelopeOutboundConnector, NearRealTimeDataMarketDocumentOutboundConnector, ValidatedHistoricalDataMarketDocumentOutboundConnector, AutoCloseable

@Component
public class AmqpOutbound
extends Object
implements AutoCloseable, ConnectionStatusMessageOutboundConnector, RawDataOutboundConnector, PermissionMarketDocumentOutboundConnector, ValidatedHistoricalDataEnvelopeOutboundConnector, AccountingPointEnvelopeOutboundConnector, NearRealTimeDataMarketDocumentOutboundConnector, ValidatedHistoricalDataMarketDocumentOutboundConnector

Constructor Summary

Constructors

Constructor	Description
AmqpOutbound(com.rabbitmq.client.amqp.Connection connection, MessageSerde serde, TopicConfiguration config)

Method Summary

Modifier and Type	Method	Description
void	close()
void	setAccountingPointEnvelopeStream(reactor.core.publisher.Flux<energy.eddie.cim.v0_82.ap.AccountingPointEnvelope> marketDocumentStream)	Sets the stream of accounting point market documents to be sent to the EP app.
void	setConnectionStatusMessageStream(reactor.core.publisher.Flux<ConnectionStatusMessage> connectionStatusMessageStream)	Sets the stream of connection status messages to be sent to the EP app.
void	setEddieValidatedHistoricalDataMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v0_82.vhd.ValidatedHistoricalDataEnvelope> marketDocumentStream)	Sets the stream of validated historical data market documents to be sent to the EP app.
void	setNearRealTimeDataMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v1_04.rtd.RTDEnvelope> marketDocumentStream)
void	setPermissionMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v0_82.pmd.PermissionEnvelope> permissionMarketDocumentStream)	Gets a flux of permission market documents
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.
void	setValidatedHistoricalDataMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v1_04.vhd.VHDEnvelope> marketDocumentStream)

Methods inherited from class java.lang.Object

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

Constructor Details

AmqpOutbound

public AmqpOutbound(com.rabbitmq.client.amqp.Connection connection,
 MessageSerde serde,
 TopicConfiguration config)

Method Details

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

setPermissionMarketDocumentStream

public void setPermissionMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v0_82.pmd.PermissionEnvelope> permissionMarketDocumentStream)

Description copied from interface: PermissionMarketDocumentOutboundConnector

Gets a flux of permission market documents

Specified by:

setPermissionMarketDocumentStream in interface PermissionMarketDocumentOutboundConnector

Parameters:

permissionMarketDocumentStream - the permission market documents

setAccountingPointEnvelopeStream

public void setAccountingPointEnvelopeStream(reactor.core.publisher.Flux<energy.eddie.cim.v0_82.ap.AccountingPointEnvelope> marketDocumentStream)

Description copied from interface: AccountingPointEnvelopeOutboundConnector

Sets the stream of accounting point market documents to be sent to the EP app.

Specified by:

setAccountingPointEnvelopeStream in interface AccountingPointEnvelopeOutboundConnector

Parameters:

marketDocumentStream - stream of accounting point market documents

setEddieValidatedHistoricalDataMarketDocumentStream

public void setEddieValidatedHistoricalDataMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v0_82.vhd.ValidatedHistoricalDataEnvelope> marketDocumentStream)

Description copied from interface: ValidatedHistoricalDataEnvelopeOutboundConnector

Sets the stream of validated historical data market documents to be sent to the EP app.

Specified by:

setEddieValidatedHistoricalDataMarketDocumentStream in interface ValidatedHistoricalDataEnvelopeOutboundConnector

Parameters:

marketDocumentStream - stream of validated historical data market documents

setNearRealTimeDataMarketDocumentStream

public void setNearRealTimeDataMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v1_04.rtd.RTDEnvelope> marketDocumentStream)

Specified by:

setNearRealTimeDataMarketDocumentStream in interface NearRealTimeDataMarketDocumentOutboundConnector

close

public void close()

Specified by:

close in interface AutoCloseable

setValidatedHistoricalDataMarketDocumentStream

public void setValidatedHistoricalDataMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v1_04.vhd.VHDEnvelope> marketDocumentStream)

Specified by:

setValidatedHistoricalDataMarketDocumentStream in interface ValidatedHistoricalDataMarketDocumentOutboundConnector