com.yahoo.bullet.rest.query

Class WebSocketQueryHandler

java.lang.Object

com.yahoo.bullet.rest.query.QueryHandler

com.yahoo.bullet.rest.query.WebSocketQueryHandler

public class WebSocketQueryHandler
extends QueryHandler

Query handler that implements results for WebSocket - multiple results per query.

Field Summary

Fields inherited from class com.yahoo.bullet.rest.query.QueryHandler

complete

Constructor Summary

Constructors

Constructor and Description
WebSocketQueryHandler(WebSocketService webSocketService, String sessionID, String queryID) Constructor method.

Method Summary

Modifier and Type	Method and Description
void	acknowledge() Indicate that the query was received and accepted by the QUERY_PROCESSING system.
void	complete() Completes the query and sets the complete flag.
void	fail(QueryError cause) Fail the query.
void	send(com.yahoo.bullet.pubsub.PubSubMessage response) Send a PubSubMessage to the query handler.

Methods inherited from class com.yahoo.bullet.rest.query.QueryHandler

fail

Methods inherited from class java.lang.Object

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

Constructor Detail

WebSocketQueryHandler

public WebSocketQueryHandler(WebSocketService webSocketService,
                             String sessionID,
                             String queryID)

Constructor method.

Parameters:

webSocketService - The WebSocketService to handle websocket messages.

sessionID - The session ID to represent the client.

queryID - The query ID.

Method Detail

complete

public void complete()

Description copied from class: QueryHandler

Completes the query and sets the complete flag. All overrides should do the same or call this.

Overrides:

complete in class QueryHandler

send

public void send(com.yahoo.bullet.pubsub.PubSubMessage response)

Description copied from class: QueryHandler

Send a PubSubMessage to the query handler.

Specified by:

send in class QueryHandler

Parameters:

response - The PubSubMessage containing a response.

fail

public void fail(QueryError cause)

Description copied from class: QueryHandler

Fail the query.

Specified by:

fail in class QueryHandler

Parameters:

cause - is the QueryError that caused the fail to be invoked.

acknowledge

public void acknowledge()

Description copied from class: QueryHandler

Indicate that the query was received and accepted by the QUERY_PROCESSING system. By default, does nothing.

Overrides:

acknowledge in class QueryHandler