Package energy.eddie.outbound.kafka

Class KafkaConnector

java.lang.Object

energy.eddie.outbound.kafka.KafkaConnector

@Component
public class KafkaConnector
extends Object

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)
void	setAcknowledgementMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v1_12.ack.AcknowledgementEnvelope> marketDocumentStream)
void	setConnectionStatusMessageStream(reactor.core.publisher.Flux<ConnectionStatusMessage> statusMessageStream)
void	setEddieValidatedHistoricalDataMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v0_82.vhd.ValidatedHistoricalDataEnvelope> marketDocumentStream)
void	setEnergySharingReferenceDataMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v1_12.esr.ESRDMDEnvelope> marketDocumentStream)
void	setNearRealTimeDataMarketDocumentStreamV1_04(reactor.core.publisher.Flux<energy.eddie.cim.v1_04.rtd.RTDEnvelope> marketDocumentStream)
void	setNearRealTimeDataMarketDocumentStreamV1_12(reactor.core.publisher.Flux<energy.eddie.cim.v1_12.rtd.RTDEnvelope> marketDocumentStream)
void	setPermissionMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v0_82.pmd.PermissionEnvelope> permissionMarketDocumentStream)
void	setRawDataStream(reactor.core.publisher.Flux<RawDataMessage> rawDataStream)
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)

setPermissionMarketDocumentStream

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

setEddieValidatedHistoricalDataMarketDocumentStream

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

setRawDataStream

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

setAccountingPointEnvelopeStream

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

setValidatedHistoricalDataMarketDocumentStream

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

setNearRealTimeDataMarketDocumentStreamV1_04

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

setNearRealTimeDataMarketDocumentStreamV1_12

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

setAcknowledgementMarketDocumentStream

public void setAcknowledgementMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v1_12.ack.AcknowledgementEnvelope> marketDocumentStream)

setEnergySharingReferenceDataMarketDocumentStream

public void setEnergySharingReferenceDataMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v1_12.esr.ESRDMDEnvelope> marketDocumentStream)