com.yahoo.bullet.rest.controller

Class WebSocketController

java.lang.Object

com.yahoo.bullet.rest.controller.MetricController

com.yahoo.bullet.rest.controller.WebSocketController

@Controller
public class WebSocketController
extends MetricController

Constructor Summary

Constructors

Constructor and Description
WebSocketController(WebSocketService webSocketService, BQLService bqlService, StatusService statusService, com.yahoo.bullet.common.metrics.MetricPublisher metricPublisher) Constructor that takes various services.

Method Summary

Modifier and Type	Method and Description
void	submitWebsocketQuery(WebSocketRequest request, org.springframework.messaging.simp.SimpMessageHeaderAccessor headerAccessor) The method that handles WebSocket messages to this endpoint.

Methods inherited from class com.yahoo.bullet.rest.controller.MetricController

incrementMetric, incrementMetric, publishMetrics, toMetric

Methods inherited from class java.lang.Object

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

Constructor Detail

WebSocketController

@Autowired
public WebSocketController(WebSocketService webSocketService,
                                      BQLService bqlService,
                                      StatusService statusService,
                                      com.yahoo.bullet.common.metrics.MetricPublisher metricPublisher)

Constructor that takes various services.

Parameters:

webSocketService - The WebSocketService to use.

bqlService - The BQLService to use.

statusService - The StatusService to use.

metricPublisher - The MetricPublisher to use. It can be null.

Method Detail

submitWebsocketQuery

@MessageMapping(value="${bullet.websocket.server.destination}")
public void submitWebsocketQuery(@Payload
                                                                                                 WebSocketRequest request,
                                                                                                 org.springframework.messaging.simp.SimpMessageHeaderAccessor headerAccessor)

The method that handles WebSocket messages to this endpoint.

Parameters:

request - The WebSocketRequest object.

headerAccessor - The SimpMessageHeaderAccessor headers associated with the message.