Interface EdaAdapter
- All Superinterfaces:
AutoCloseable
- All Known Implementing Classes:
PontonXPAdapter
This interface defines the methods that must be provided by classes that facilitate the communication with EDA. The
returned classes are part of the EDA schemas and are generated by the JAXB compiler.
-
Method Summary
Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<CMRequestStatus> Returns a stream of CMRequestStatus objects that describe the current permission/consent status of all sent requests.reactor.core.publisher.Flux<EdaCMRevoke> Returns a stream of EdaCMRevoke objects that contain information regarding revoked permissions/consents.reactor.core.publisher.Flux<IdentifiableConsumptionRecord> Returns a stream of EdaConsumptionRecord objects tha contain information regarding energy consumption for a specific metering point.reactor.core.publisher.Flux<CPRequestResult> Returns a stream of CPRequestResult objects that contain information regarding the response of a CPRequestCR.reactor.core.publisher.Flux<IdentifiableMasterData> Returns a stream of EdaMasterData objects that contain information regarding metering points and their owners.voidsendCMRequest(CCMORequest request) This method sends a CCMORequest to EDA.voidsendCMRevoke(CCMORevoke revoke) This method sends a CCMORevoke to EDA.voidsendCPRequest(CPRequestCR cpRequestCR) This method sends a CPRequest that request the retransmission of Consumption Records.voidstart()This method starts the connection to EDA.Methods inherited from interface java.lang.AutoCloseable
close
-
Method Details
-
getCMRequestStatusStream
reactor.core.publisher.Flux<CMRequestStatus> getCMRequestStatusStream()Returns a stream of CMRequestStatus objects that describe the current permission/consent status of all sent requests. -
getConsumptionRecordStream
reactor.core.publisher.Flux<IdentifiableConsumptionRecord> getConsumptionRecordStream()Returns a stream of EdaConsumptionRecord objects tha contain information regarding energy consumption for a specific metering point. -
getCMRevokeStream
reactor.core.publisher.Flux<EdaCMRevoke> getCMRevokeStream()Returns a stream of EdaCMRevoke objects that contain information regarding revoked permissions/consents. -
getMasterDataStream
reactor.core.publisher.Flux<IdentifiableMasterData> getMasterDataStream()Returns a stream of EdaMasterData objects that contain information regarding metering points and their owners. -
getCPRequestResultStream
reactor.core.publisher.Flux<CPRequestResult> getCPRequestResultStream()Returns a stream of CPRequestResult objects that contain information regarding the response of a CPRequestCR. -
sendCMRequest
This method sends a CCMORequest to EDA. A CCORequest can be used to request either metering or master data.- Parameters:
request- The CCMORequest message that should be sent to EDA.- Throws:
TransmissionException- If the request could not be sent. Reasons can be a connection error or a malformed request.
-
sendCMRevoke
This method sends a CCMORevoke to EDA. A CCMORevoke can be used to revoke an active permission/consent.- Parameters:
revoke- The CCMORevoke message that should be sent to EDA.- Throws:
TransmissionException- If the request could not be sent. Reasons can be a connection error or a malformed request.
-
sendCPRequest
This method sends a CPRequest that request the retransmission of Consumption Records.- Parameters:
cpRequestCR- The CPRequestCR message that should be sent to EDA.- Throws:
TransmissionException- If the request could not be sent. Reasons can be a connection error or a malformed request.
-
start
This method starts the connection to EDA. It must be called before any of the methods that use the connection can be used.- Throws:
TransmissionException- If the connection to EDA could not be established.
-