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:

TerminationConnector, AutoCloseable

@Component
public class CimConnector
extends Object
implements TerminationConnector, AutoCloseable

Constructor Summary

Constructors

Constructor	Description
CimConnector()

Method Summary

Modifier and Type	Method	Description
void	close()
reactor.core.publisher.Flux<energy.eddie.cim.v0_82.ap.AccountingPointEnvelope>	getAccountingPointDataMarketDocumentStream()
reactor.core.publisher.Flux<energy.eddie.cim.v0_82.vhd.ValidatedHistoricalDataEnvelope>	getHistoricalDataMarketDocumentStream()
reactor.core.publisher.Flux<energy.eddie.cim.v0_82.pmd.PermissionEnvelope>	getPermissionMarketDocumentStream()
reactor.core.publisher.Flux<Pair<String,energy.eddie.cim.v0_82.pmd.PermissionEnvelope>>	getTerminationMessages()	A flux of termination documents, which are special permission market documents, and an optional region-connector ID as String.
void	publish(energy.eddie.cim.v0_82.pmd.PermissionEnvelope permissionEnvelope)
void	setAccountingPointEnvelopeStream(reactor.core.publisher.Flux<energy.eddie.cim.v0_82.ap.AccountingPointEnvelope> marketDocumentStream)
void	setEddieValidatedHistoricalDataMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v0_82.vhd.ValidatedHistoricalDataEnvelope> marketDocumentStream)
void	setPermissionMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v0_82.pmd.PermissionEnvelope> permissionMarketDocumentStream)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CimConnector

public CimConnector()

Method Details

setEddieValidatedHistoricalDataMarketDocumentStream

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

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)

setAccountingPointEnvelopeStream

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

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