java.lang.Object
energy.eddie.outbound.rest.connectors.cim.v1_04.CimConnector
All Implemented Interfaces:
AutoCloseable

@Component("cimConnectorV1_04") public class CimConnector extends Object implements AutoCloseable
  • 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)
    • 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)
    • close

      public void close()
      Specified by:
      close in interface AutoCloseable