Package energy.eddie.regionconnector.at.eda.ponton

Class PontonXPAdapter

java.lang.Object

energy.eddie.regionconnector.at.eda.ponton.PontonXPAdapter

All Implemented Interfaces:

EdaAdapter, AutoCloseable

public class PontonXPAdapter
extends Object
implements EdaAdapter

Constructor Summary

Constructors

Constructor	Description
PontonXPAdapter(PontonMessengerConnection pontonMessengerConnection, IdentifiableConsumptionRecordService identifiableConsumptionRecordService, IdentifiableMasterDataService identifiableMasterDataService, org.springframework.scheduling.TaskScheduler scheduler)

Method Summary

Modifier and Type	Method	Description
void	close()
reactor.core.publisher.Flux<CMRequestStatus>	getCMRequestStatusStream()	Returns a stream of CMRequestStatus objects that describe the current permission/consent status of all sent requests.
reactor.core.publisher.Flux<EdaCMRevoke>	getCMRevokeStream()	Returns a stream of EdaCMRevoke objects that contain information regarding revoked permissions/consents.
reactor.core.publisher.Flux<IdentifiableConsumptionRecord>	getConsumptionRecordStream()	Returns a stream of EdaConsumptionRecord objects tha contain information regarding energy consumption for a specific metering point.
reactor.core.publisher.Flux<CPRequestResult>	getCPRequestResultStream()	Returns a stream of CPRequestResult objects that contain information regarding the response of a CPRequestCR.
reactor.core.publisher.Flux<IdentifiableMasterData>	getMasterDataStream()	Returns a stream of EdaMasterData objects that contain information regarding metering points and their owners.
void	sendCMRequest(CCMORequest request)	This method sends a CCMORequest to EDA.
void	sendCMRevoke(CCMORevoke revoke)	This method sends a CCMORevoke to EDA.
void	sendCPRequest(CPRequestCR cpRequestCR)	This method sends a CPRequest that request the retransmission of Consumption Records.
void	start()	This method starts the connection to EDA.

Methods inherited from class java.lang.Object

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

Constructor Details

PontonXPAdapter

public PontonXPAdapter(PontonMessengerConnection pontonMessengerConnection,
 IdentifiableConsumptionRecordService identifiableConsumptionRecordService,
 IdentifiableMasterDataService identifiableMasterDataService,
 org.springframework.scheduling.TaskScheduler scheduler)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

getCMRequestStatusStream

public reactor.core.publisher.Flux<CMRequestStatus> getCMRequestStatusStream()

Description copied from interface: EdaAdapter

Returns a stream of CMRequestStatus objects that describe the current permission/consent status of all sent requests.

Specified by:

getCMRequestStatusStream in interface EdaAdapter

getConsumptionRecordStream

public reactor.core.publisher.Flux<IdentifiableConsumptionRecord> getConsumptionRecordStream()

Description copied from interface: EdaAdapter

Returns a stream of EdaConsumptionRecord objects tha contain information regarding energy consumption for a specific metering point.

Specified by:

getConsumptionRecordStream in interface EdaAdapter

getCMRevokeStream

public reactor.core.publisher.Flux<EdaCMRevoke> getCMRevokeStream()

Description copied from interface: EdaAdapter

Returns a stream of EdaCMRevoke objects that contain information regarding revoked permissions/consents.

Specified by:

getCMRevokeStream in interface EdaAdapter

getMasterDataStream

public reactor.core.publisher.Flux<IdentifiableMasterData> getMasterDataStream()

Description copied from interface: EdaAdapter

Returns a stream of EdaMasterData objects that contain information regarding metering points and their owners.

Specified by:

getMasterDataStream in interface EdaAdapter

getCPRequestResultStream

public reactor.core.publisher.Flux<CPRequestResult> getCPRequestResultStream()

Description copied from interface: EdaAdapter

Returns a stream of CPRequestResult objects that contain information regarding the response of a CPRequestCR.

Specified by:

getCPRequestResultStream in interface EdaAdapter

sendCMRequest

public void sendCMRequest(CCMORequest request)
                   throws TransmissionException

Description copied from interface: EdaAdapter

This method sends a CCMORequest to EDA. A CCORequest can be used to request either metering or master data.

Specified by:

sendCMRequest in interface EdaAdapter

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

public void sendCMRevoke(CCMORevoke revoke)
                  throws TransmissionException

Description copied from interface: EdaAdapter

This method sends a CCMORevoke to EDA. A CCMORevoke can be used to revoke an active permission/consent.

Specified by:

sendCMRevoke in interface EdaAdapter

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

public void sendCPRequest(CPRequestCR cpRequestCR)
                   throws TransmissionException

Description copied from interface: EdaAdapter

This method sends a CPRequest that request the retransmission of Consumption Records.

Specified by:

sendCPRequest in interface EdaAdapter

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

public void start()
           throws TransmissionException

Description copied from interface: EdaAdapter

This method starts the connection to EDA. It must be called before any of the methods that use the connection can be used.

Specified by:

start in interface EdaAdapter

Throws:

TransmissionException - If the connection to EDA could not be established.