Package energy.eddie.outbound.rest.web

Class AgnosticController

java.lang.Object

energy.eddie.outbound.rest.web.AgnosticController

@RestController
@RequestMapping("agnostic")
public class AgnosticController
extends Object

Constructor Summary

Constructors

Constructor	Description
AgnosticController(AgnosticConnector agnosticConnector, ConnectionStatusMessageRepository csmRepository, RawDataMessageRepository rawDataRepository)

Method Summary

Modifier and Type	Method	Description
org.springframework.http.ResponseEntity<ConnectionStatusMessages>	connectionStatusMessages(Optional<String> permissionId, Optional<String> connectionId, Optional<String> dataNeedId, Optional<@Valid @Pattern(regexp="[A-Z]{2}") String> countryCode, Optional<String> regionConnectorId, Optional<ZonedDateTime> from, Optional<ZonedDateTime> to)
org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<ConnectionStatusMessage>>	connectionStatusMessagesSSE()
org.springframework.http.ResponseEntity<RawDataMessages>	rawDataMessages(Optional<String> permissionId, Optional<String> connectionId, Optional<String> dataNeedId, Optional<String> countryCode, Optional<String> regionConnectorId, Optional<ZonedDateTime> from, Optional<ZonedDateTime> to)
org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<RawDataMessage>>	rawDataMessagesSSE()

Methods inherited from class java.lang.Object

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

Constructor Details

AgnosticController

public AgnosticController(AgnosticConnector agnosticConnector,
 ConnectionStatusMessageRepository csmRepository,
 RawDataMessageRepository rawDataRepository)

Method Details

connectionStatusMessagesSSE

@GetMapping(value="/connection-status-messages",
            produces="text/event-stream")
public org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<ConnectionStatusMessage>> connectionStatusMessagesSSE()

connectionStatusMessages

@GetMapping(value="/connection-status-messages",
            produces={"application/json","application/xml"})
public org.springframework.http.ResponseEntity<ConnectionStatusMessages> connectionStatusMessages(@RequestParam(required=false)
 Optional<String> permissionId,
 @RequestParam(required=false)
 Optional<String> connectionId,
 @RequestParam(required=false)
 Optional<String> dataNeedId,
 @RequestParam(required=false)
 Optional<@Valid @Pattern(regexp="[A-Z]{2}") String> countryCode,
 @RequestParam(required=false)
 Optional<String> regionConnectorId,
 @RequestParam(required=false)
 Optional<ZonedDateTime> from,
 @RequestParam(required=false)
 Optional<ZonedDateTime> to)

rawDataMessagesSSE

@GetMapping(value="/raw-data-messages",
            produces="text/event-stream")
public org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<RawDataMessage>> rawDataMessagesSSE()

rawDataMessages

@GetMapping(value="/raw-data-messages",
            produces={"application/json","application/xml"})
public org.springframework.http.ResponseEntity<RawDataMessages> rawDataMessages(@RequestParam(required=false)
 Optional<String> permissionId,
 @RequestParam(required=false)
 Optional<String> connectionId,
 @RequestParam(required=false)
 Optional<String> dataNeedId,
 @RequestParam(required=false)
 Optional<String> countryCode,
 @RequestParam(required=false)
 Optional<String> regionConnectorId,
 @RequestParam(required=false)
 Optional<ZonedDateTime> from,
 @RequestParam(required=false)
 Optional<ZonedDateTime> to)