Package energy.eddie.outbound.kafka

Class KafkaConnector

java.lang.Object

energy.eddie.outbound.kafka.KafkaConnector

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor	Description
KafkaConnector(org.springframework.kafka.core.KafkaTemplate<String,Object> kafkaTemplate, TopicConfiguration config)

Method Summary

Modifier and Type	Method	Description
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> statusMessageStream)	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

KafkaConnector

public KafkaConnector(org.springframework.kafka.core.KafkaTemplate<String,Object> kafkaTemplate,
 TopicConfiguration config)

Method Details

setConnectionStatusMessageStream

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

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:

statusMessageStream - stream of connection status 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

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

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

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

setValidatedHistoricalDataMarketDocumentStream

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

Specified by:

setValidatedHistoricalDataMarketDocumentStream in interface ValidatedHistoricalDataMarketDocumentOutboundConnector

setNearRealTimeDataMarketDocumentStream

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

Specified by:

setNearRealTimeDataMarketDocumentStream in interface NearRealTimeDataMarketDocumentOutboundConnector