Package com.aquima.web.api.controller.v2

Class SseController

java.lang.Object

com.aquima.web.api.controller.v2.AbstractBaseController

com.aquima.web.api.controller.v2.SseController

@ServerContext
@RestController("v2ApiSseController")
public class SseController
extends AbstractBaseController

This controller provides a Server Sent Event endpoint for messages pushed to the SsePushChannel

Constructor Summary

Constructors

Constructor	Description
SseController(com.blueriq.component.api.push.channel.PushChannelRetriever pushChannel)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<org.springframework.http.codec.ServerSentEvent<String>>	getEvents(javax.servlet.http.HttpSession httpSession, String lastEventId)

Methods inherited from class com.aquima.web.api.controller.v2.AbstractBaseController

clientParametersException, handleConversionException, handleDecisionTreeNotExposedException, handleEmptySymptomException, handleFlowEndedException, handleForbiddenException, handleFunctionParameterException, handleFunctionValidationException, handleFunctionValidationException, handleMethodArgumentTypeMismatchException, handleRequestWardException, handleStartApplicationForbiddenException, handleStartShortcutForbiddenException, handleUnauthorizedException, handleUnknownApplicationException, handleUnknownDecisionTreeException, handleUnknownFlowException, handleUnknownFunctionFlowException, handleUnknownLanguageException, handleUnknownModuleException, handleUnknownSessionException, handleUnknownShortcutException, handleUnknownSubscriptionException, handleUnsupportedOpenApiSpecException, isAuthenticated

Methods inherited from class java.lang.Object

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

Constructor Detail

SseController

@Autowired
public SseController(com.blueriq.component.api.push.channel.PushChannelRetriever pushChannel)

Method Detail

getEvents

@GetMapping(path="/api/v2/push-messages")
public reactor.core.publisher.Flux<org.springframework.http.codec.ServerSentEvent<String>> getEvents(javax.servlet.http.HttpSession httpSession,
                                                                                                     @RequestParam(name="Last-Event-ID",required=false)
                                                                                                     String lastEventId)