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

Class PontonMessengerConnectionImpl

java.lang.Object

energy.eddie.regionconnector.at.eda.ponton.messenger.PontonMessengerConnectionImpl

All Implemented Interfaces:

MessengerHealth, MessengerMonitor, PontonMessengerConnection, AutoCloseable

public class PontonMessengerConnectionImpl
extends Object
implements AutoCloseable, PontonMessengerConnection

Constructor Summary

Constructors

Constructor	Description
PontonMessengerConnectionImpl(PontonXPAdapterConfiguration config, File workFolder, InboundMessageFactoryCollection inboundMessageFactoryCollection, OutboundMessageFactoryCollection outboundMessageFactoryCollection, MessengerHealth healthApi, MessengerMonitor messengerMonitor)

Method Summary

Modifier and Type	Method	Description
void	close()
MessengerStatus	messengerStatus()
void	resendFailedMessage(ZonedDateTime date, String messageId)
void	sendCMRequest(CCMORequest ccmoRequest)
void	sendCMRevoke(CCMORevoke ccmoRevoke)
void	sendCPRequest(CPRequestCR cpRequestCR)
void	sendMessage(de.ponton.xp.adapter.api.messages.OutboundMessage outboundMessage)
void	start()
PontonMessengerConnection	withCMNotificationHandler(CMNotificationHandler cmNotificationHandler)
PontonMessengerConnection	withCMRevokeHandler(CMRevokeHandler cmRevokeHandler)
PontonMessengerConnection	withConsumptionRecordHandler(ConsumptionRecordHandler consumptionRecordHandler)
PontonMessengerConnection	withCPNotificationHandler(CPNotificationHandler cpNotificationHandler)
PontonMessengerConnection	withMasterDataHandler(MasterDataHandler masterDataHandler)
PontonMessengerConnection	withOutboundMessageStatusUpdateHandler(de.ponton.xp.adapter.api.OutboundMessageStatusUpdateHandler outboundMessageStatusUpdateHandler)

Methods inherited from class java.lang.Object

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

Constructor Details

PontonMessengerConnectionImpl

public PontonMessengerConnectionImpl(PontonXPAdapterConfiguration config,
 File workFolder,
 InboundMessageFactoryCollection inboundMessageFactoryCollection,
 OutboundMessageFactoryCollection outboundMessageFactoryCollection,
 MessengerHealth healthApi,
 MessengerMonitor messengerMonitor)
                              throws de.ponton.xp.adapter.api.ConnectionException

Throws:

de.ponton.xp.adapter.api.ConnectionException

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface PontonMessengerConnection

start

public void start()
           throws de.ponton.xp.adapter.api.TransmissionException

Specified by:

start in interface PontonMessengerConnection

Throws:

de.ponton.xp.adapter.api.TransmissionException

sendCMRevoke

public void sendCMRevoke(CCMORevoke ccmoRevoke)
                  throws de.ponton.xp.adapter.api.TransmissionException,
de.ponton.xp.adapter.api.ConnectionException

Specified by:

sendCMRevoke in interface PontonMessengerConnection

Throws:

de.ponton.xp.adapter.api.TransmissionException

de.ponton.xp.adapter.api.ConnectionException

sendCMRequest

public void sendCMRequest(CCMORequest ccmoRequest)
                   throws de.ponton.xp.adapter.api.TransmissionException,
de.ponton.xp.adapter.api.ConnectionException

Specified by:

sendCMRequest in interface PontonMessengerConnection

Throws:

de.ponton.xp.adapter.api.TransmissionException

de.ponton.xp.adapter.api.ConnectionException

sendCPRequest

public void sendCPRequest(CPRequestCR cpRequestCR)
                   throws de.ponton.xp.adapter.api.TransmissionException,
de.ponton.xp.adapter.api.ConnectionException

Specified by:

sendCPRequest in interface PontonMessengerConnection

Throws:

de.ponton.xp.adapter.api.TransmissionException

de.ponton.xp.adapter.api.ConnectionException

withOutboundMessageStatusUpdateHandler

public PontonMessengerConnection withOutboundMessageStatusUpdateHandler(de.ponton.xp.adapter.api.OutboundMessageStatusUpdateHandler outboundMessageStatusUpdateHandler)

Specified by:

withOutboundMessageStatusUpdateHandler in interface PontonMessengerConnection

withCMNotificationHandler

public PontonMessengerConnection withCMNotificationHandler(CMNotificationHandler cmNotificationHandler)

Specified by:

withCMNotificationHandler in interface PontonMessengerConnection

withCMRevokeHandler

public PontonMessengerConnection withCMRevokeHandler(CMRevokeHandler cmRevokeHandler)

Specified by:

withCMRevokeHandler in interface PontonMessengerConnection

withConsumptionRecordHandler

public PontonMessengerConnection withConsumptionRecordHandler(ConsumptionRecordHandler consumptionRecordHandler)

Specified by:

withConsumptionRecordHandler in interface PontonMessengerConnection

withMasterDataHandler

public PontonMessengerConnection withMasterDataHandler(MasterDataHandler masterDataHandler)

Specified by:

withMasterDataHandler in interface PontonMessengerConnection

withCPNotificationHandler

public PontonMessengerConnection withCPNotificationHandler(CPNotificationHandler cpNotificationHandler)

Specified by:

withCPNotificationHandler in interface PontonMessengerConnection

sendMessage

public void sendMessage(de.ponton.xp.adapter.api.messages.OutboundMessage outboundMessage)
                 throws de.ponton.xp.adapter.api.TransmissionException,
de.ponton.xp.adapter.api.ConnectionException

Throws:

de.ponton.xp.adapter.api.TransmissionException

de.ponton.xp.adapter.api.ConnectionException

messengerStatus

public MessengerStatus messengerStatus()

Specified by:

messengerStatus in interface MessengerHealth

resendFailedMessage

public void resendFailedMessage(ZonedDateTime date,
 String messageId)

Specified by:

resendFailedMessage in interface MessengerMonitor