Class CimConnector
java.lang.Object
energy.eddie.outbound.rest.connectors.cim.v1_04.CimConnector
- All Implemented Interfaces:
NearRealTimeDataMarketDocumentOutboundConnectorV1_04,ValidatedHistoricalDataMarketDocumentOutboundConnector,AutoCloseable
@Component("cimConnectorV1_04")
public class CimConnector
extends Object
implements ValidatedHistoricalDataMarketDocumentOutboundConnector, NearRealTimeDataMarketDocumentOutboundConnectorV1_04, AutoCloseable
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()reactor.core.publisher.Flux<energy.eddie.cim.v1_04.rtd.RTDEnvelope> reactor.core.publisher.Flux<energy.eddie.cim.v1_04.vhd.VHDEnvelope> voidsetNearRealTimeDataMarketDocumentStreamV1_04(reactor.core.publisher.Flux<energy.eddie.cim.v1_04.rtd.RTDEnvelope> marketDocumentStream) voidsetValidatedHistoricalDataMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v1_04.vhd.VHDEnvelope> marketDocumentStream)
-
Constructor Details
-
CimConnector
public CimConnector()
-
-
Method Details
-
getValidatedHistoricalDataMarketDocumentStream
public reactor.core.publisher.Flux<energy.eddie.cim.v1_04.vhd.VHDEnvelope> getValidatedHistoricalDataMarketDocumentStream() -
setValidatedHistoricalDataMarketDocumentStream
public void setValidatedHistoricalDataMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v1_04.vhd.VHDEnvelope> marketDocumentStream) - Specified by:
setValidatedHistoricalDataMarketDocumentStreamin interfaceValidatedHistoricalDataMarketDocumentOutboundConnector
-
getNearRealTimeDataMarketDocumentStream
public reactor.core.publisher.Flux<energy.eddie.cim.v1_04.rtd.RTDEnvelope> getNearRealTimeDataMarketDocumentStream() -
setNearRealTimeDataMarketDocumentStreamV1_04
public void setNearRealTimeDataMarketDocumentStreamV1_04(reactor.core.publisher.Flux<energy.eddie.cim.v1_04.rtd.RTDEnvelope> marketDocumentStream) - Specified by:
setNearRealTimeDataMarketDocumentStreamV1_04in interfaceNearRealTimeDataMarketDocumentOutboundConnectorV1_04
-
close
public void close()- Specified by:
closein interfaceAutoCloseable
-