Package energy.eddie.outbound.rest.connectors.cim.v0_82

Class CimConnector

java.lang.Object
energy.eddie.outbound.rest.connectors.cim.v0_82.CimConnector
All Implemented Interfaces:
AccountingPointEnvelopeOutboundConnector, PermissionMarketDocumentOutboundConnector, TerminationConnector, ValidatedHistoricalDataEnvelopeOutboundConnector, AutoCloseable
@Component public class CimConnector extends Object implements ValidatedHistoricalDataEnvelopeOutboundConnector, PermissionMarketDocumentOutboundConnector, AccountingPointEnvelopeOutboundConnector, TerminationConnector, AutoCloseable

  • Constructor Details

    • CimConnector

      public CimConnector()

  • Method Details

    • 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

    • getHistoricalDataMarketDocumentStream

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

    • getPermissionMarketDocumentStream

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

    • 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

    • getAccountingPointDataMarketDocumentStream

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

    • getTerminationMessages

      public reactor.core.publisher.Flux<Pair<String,energy.eddie.cim.v0_82.pmd.PermissionEnvelope>> getTerminationMessages()
      Description copied from interface: TerminationConnector
      A flux of termination documents, which are special permission market documents, and an optional region-connector ID as String.
      Specified by:
      getTerminationMessages in interface TerminationConnector
      Returns:
      A pair of an optional region-connector ID and a termination market document.

    • publish

      public void publish(energy.eddie.cim.v0_82.pmd.PermissionEnvelope permissionEnvelope)

    • close

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

    • createSink

      public static <T> reactor.core.publisher.Sinks.Many<T> createSink()