com.yahoo.bullet.rest.query

Class QueryHandler

java.lang.Object

com.yahoo.bullet.rest.query.QueryHandler

Direct Known Subclasses:

HTTPQueryHandler, SSEQueryHandler, WebSocketQueryHandler

public abstract class QueryHandler
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	complete

Constructor Summary

Constructors

Constructor and Description
QueryHandler()

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() Convenience method that fails a query with a generic service unavailable error.
abstract void	fail(QueryError cause) Fail the query.
abstract void	send(com.yahoo.bullet.pubsub.PubSubMessage message) Send a PubSubMessage to the query handler.

Methods inherited from class java.lang.Object

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

Field Detail

complete

protected boolean complete

Constructor Detail

QueryHandler

public QueryHandler()

Method Detail

send

public abstract void send(com.yahoo.bullet.pubsub.PubSubMessage message)

Send a PubSubMessage to the query handler.

Parameters:

message - The PubSubMessage containing a response.

complete

public void complete()

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

fail

public abstract void fail(QueryError cause)

Fail the query.

Parameters:

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

acknowledge

public void acknowledge()

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

fail

public void fail()

Convenience method that fails a query with a generic service unavailable error.