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
ConstructorsConstructorDescriptionWebPontonConnectionController(InboundMessageFactoryCollection inboundMessageFactoryCollection, OutboundMessageFactoryCollection outboundMessageFactoryCollection) -
Method Summary
Modifier and TypeMethodDescriptionorg.springframework.http.ResponseEntity<reactor.core.publisher.Flux<String>> voidclose()org.springframework.http.ResponseEntity<Void> cmNotification(jakarta.servlet.http.HttpServletRequest request, NotificationMessageType type) org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<String>> 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>> org.springframework.http.ResponseEntity<Void> masterData(jakarta.servlet.http.HttpServletRequest request) voidresendFailedMessage(ZonedDateTime date, String messageId) voidsendCMRequest(CCMORequest ccmoRequest) voidsendCMRevoke(CCMORevoke ccmoRevoke) voidsendCPRequest(CPRequestCR cpRequestCR) voidstart()withCMNotificationHandler(CMNotificationHandler cmNotificationHandler) withCMRevokeHandler(CMRevokeHandler cmRevokeHandler) withConsumptionRecordHandler(ConsumptionRecordHandler consumptionRecordHandler) withCPNotificationHandler(CPNotificationHandler cpNotificationHandler) withMasterDataHandler(MasterDataHandler masterDataHandler) withOutboundMessageStatusUpdateHandler(de.ponton.xp.adapter.api.OutboundMessageStatusUpdateHandler outboundMessageStatusUpdateHandler)
-
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
- Specified by:
messengerStatusin interfaceMessengerHealth
-
resendFailedMessage
- Specified by:
resendFailedMessagein interfaceMessengerMonitor
-
close
public void close()- Specified by:
closein interfacePontonMessengerConnection
-
start
public void start() throws de.ponton.xp.adapter.api.TransmissionException- Specified by:
startin interfacePontonMessengerConnection- Throws:
de.ponton.xp.adapter.api.TransmissionException
-
sendCMRevoke
- Specified by:
sendCMRevokein interfacePontonMessengerConnection- Throws:
de.ponton.xp.adapter.api.ConnectionException
-
sendCMRequest
public void sendCMRequest(CCMORequest ccmoRequest) throws de.ponton.xp.adapter.api.ConnectionException - Specified by:
sendCMRequestin interfacePontonMessengerConnection- Throws:
de.ponton.xp.adapter.api.ConnectionException
-
sendCPRequest
public void sendCPRequest(CPRequestCR cpRequestCR) throws de.ponton.xp.adapter.api.ConnectionException - Specified by:
sendCPRequestin interfacePontonMessengerConnection- Throws:
de.ponton.xp.adapter.api.ConnectionException
-
withOutboundMessageStatusUpdateHandler
public PontonMessengerConnection withOutboundMessageStatusUpdateHandler(de.ponton.xp.adapter.api.OutboundMessageStatusUpdateHandler outboundMessageStatusUpdateHandler) - Specified by:
withOutboundMessageStatusUpdateHandlerin interfacePontonMessengerConnection
-
withCMNotificationHandler
public PontonMessengerConnection withCMNotificationHandler(CMNotificationHandler cmNotificationHandler) - Specified by:
withCMNotificationHandlerin interfacePontonMessengerConnection
-
withCMRevokeHandler
- Specified by:
withCMRevokeHandlerin interfacePontonMessengerConnection
-
withConsumptionRecordHandler
public PontonMessengerConnection withConsumptionRecordHandler(ConsumptionRecordHandler consumptionRecordHandler) - Specified by:
withConsumptionRecordHandlerin interfacePontonMessengerConnection
-
withMasterDataHandler
- Specified by:
withMasterDataHandlerin interfacePontonMessengerConnection
-
withCPNotificationHandler
public PontonMessengerConnection withCPNotificationHandler(CPNotificationHandler cpNotificationHandler) - Specified by:
withCPNotificationHandlerin interfacePontonMessengerConnection
-