Package energy.eddie.regionconnector.at.eda.web

Class WebPontonConnectionController

java.lang.Object

energy.eddie.regionconnector.at.eda.web.WebPontonConnectionController

All Implemented Interfaces:

MessengerHealth, MessengerMonitor, PontonMessengerConnection

@RestController
@RequestMapping("/ponton")
@ConditionalOnProperty(value="region-connector.at.eda.ponton.messenger.enabled",
                       havingValue="false")
public class WebPontonConnectionController
extends Object
implements PontonMessengerConnection

Constructor Summary

Constructors

Constructor	Description
WebPontonConnectionController(InboundMessageFactoryCollection inboundMessageFactoryCollection, OutboundMessageFactoryCollection outboundMessageFactoryCollection)

Method Summary

Modifier and Type	Method	Description
org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<String>>	ccmoRevoke()
void	close()
org.springframework.http.ResponseEntity<Void>	cmNotification(jakarta.servlet.http.HttpServletRequest request, NotificationMessageType type)
org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<String>>	cmRequest()
org.springframework.http.ResponseEntity<Void>	cmRevoke(jakarta.servlet.http.HttpServletRequest request)
org.springframework.http.ResponseEntity<Void>	consumptionRecord(jakarta.servlet.http.HttpServletRequest request)
org.springframework.http.ResponseEntity<Void>	cpNotification(jakarta.servlet.http.HttpServletRequest request, CPNotificationMessageType type)
org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<String>>	cpRequest()
org.springframework.http.ResponseEntity<Void>	masterData(jakarta.servlet.http.HttpServletRequest request)
MessengerStatus	messengerStatus()
void	resendFailedMessage(ZonedDateTime date, String messageId)
void	sendCMRequest(CCMORequest ccmoRequest)
void	sendCMRevoke(CCMORevoke ccmoRevoke)
void	sendCPRequest(CPRequestCR cpRequestCR)
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

WebPontonConnectionController

public WebPontonConnectionController(InboundMessageFactoryCollection inboundMessageFactoryCollection,
 OutboundMessageFactoryCollection outboundMessageFactoryCollection)

Method Details

cmNotification

@PostMapping(value="/cm-notification/{type}",
             consumes="application/xml")
public org.springframework.http.ResponseEntity<Void> cmNotification(jakarta.servlet.http.HttpServletRequest request,
 @PathVariable
 NotificationMessageType type)
                                                             throws IOException

Throws:

IOException

cmRevoke

@PostMapping(value="/cm-revoke",
             consumes="application/xml")
public org.springframework.http.ResponseEntity<Void> cmRevoke(jakarta.servlet.http.HttpServletRequest request)
                                                       throws IOException

Throws:

IOException

consumptionRecord

@PostMapping(value="/consumption-record",
             consumes="application/xml")
public org.springframework.http.ResponseEntity<Void> consumptionRecord(jakarta.servlet.http.HttpServletRequest request)
                                                                throws IOException

Throws:

IOException

masterData

@PostMapping(value="/master-data",
             consumes="application/xml")
public org.springframework.http.ResponseEntity<Void> masterData(jakarta.servlet.http.HttpServletRequest request)
                                                         throws IOException

Throws:

IOException

cpNotification

@PostMapping("/cp-notification/{type}")
public org.springframework.http.ResponseEntity<Void> cpNotification(jakarta.servlet.http.HttpServletRequest request,
 @PathVariable
 CPNotificationMessageType type)
                                                             throws IOException

Throws:

IOException

cmRequest

@GetMapping(value="/cm-request",
            produces="text/event-stream")
public org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<String>> cmRequest()

ccmoRevoke

@GetMapping(value="/ccmo-revoke",
            produces="text/event-stream")
public org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<String>> ccmoRevoke()

cpRequest

@GetMapping(value="/cp-request",
            produces="text/event-stream")
public org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<String>> cpRequest()

messengerStatus

public MessengerStatus messengerStatus()

Specified by:

messengerStatus in interface MessengerHealth

resendFailedMessage

public void resendFailedMessage(ZonedDateTime date,
 String messageId)

Specified by:

resendFailedMessage in interface MessengerMonitor

close

public void close()

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.ConnectionException

Specified by:

sendCMRevoke in interface PontonMessengerConnection

Throws:

de.ponton.xp.adapter.api.ConnectionException

sendCMRequest

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

Specified by:

sendCMRequest in interface PontonMessengerConnection

Throws:

de.ponton.xp.adapter.api.ConnectionException

sendCPRequest

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

Specified by:

sendCPRequest in interface PontonMessengerConnection

Throws:

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