com.yahoo.bullet.rest.service

Class HandlerService

java.lang.Object

com.yahoo.bullet.pubsub.PubSubResponder

com.yahoo.bullet.rest.service.HandlerService

All Implemented Interfaces:

AutoCloseable

@Service
public class HandlerService
extends com.yahoo.bullet.pubsub.PubSubResponder

This is used for synchronous sending and handling of queries. To store and manage QueryHandler instances.

Field Summary

Fields inherited from class com.yahoo.bullet.pubsub.PubSubResponder

config

Constructor Summary

Constructors

Constructor and Description
HandlerService() Constructor that creates a responder.

Method Summary

Modifier and Type	Method and Description
void	addHandler(String id, QueryHandler handler) Adds the given QueryHandler for the given ID to this service.
void	close() Stop all service threads and clear pending handlers.
int	count() Get the number of running handlers.
void	failAllHandlers() Clears all pending handlers.
boolean	failHandler(String id) Fail a given handler, if it exists.
QueryHandler	getHandler(String id) Retrieves the QueryHandler for the given ID, if it exists.
boolean	hasHandler(String id) Checks to see if a given handler exists.
QueryHandler	removeHandler(String id) Removes a QueryHandler for the given ID.
void	respond(String id, com.yahoo.bullet.pubsub.PubSubMessage message)

Methods inherited from class java.lang.Object

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

Constructor Detail

HandlerService

@Autowired
public HandlerService()

Constructor that creates a responder.

Method Detail

respond

public void respond(String id,
                    com.yahoo.bullet.pubsub.PubSubMessage message)

Specified by:

respond in class com.yahoo.bullet.pubsub.PubSubResponder

addHandler

public void addHandler(String id,
                       QueryHandler handler)

Adds the given QueryHandler for the given ID to this service.

Parameters:

id - The ID of the handler.

handler - The QueryHandler instance to add.

getHandler

public QueryHandler getHandler(String id)

Retrieves the QueryHandler for the given ID, if it exists.

Parameters:

id - The ID of the handler.

Returns:

The QueryHandler instance or null if the handler does not exist.

removeHandler

public QueryHandler removeHandler(String id)

Removes a QueryHandler for the given ID.

Parameters:

id - The ID of the handler.

Returns:

The QueryHandler instance or null if the handler does not exist.

hasHandler

public boolean hasHandler(String id)

Checks to see if a given handler exists.

Parameters:

id - The ID of the handler.

Returns:

A boolean denoting if the handler exists in this service.

failHandler

public boolean failHandler(String id)

Fail a given handler, if it exists. This does not submit anything to Bullet. It simply removes the handler and invokes its QueryHandler.fail() method.

Parameters:

id - The ID of a handler to fail, if it exists.

Returns:

true if the handler was failed.

failAllHandlers

public void failAllHandlers()

Clears all pending handlers. This does not send anything to Bullet.

count

public int count()

Get the number of running handlers.

Returns:

The number of running handlers.

close

@PreDestroy
public void close()

Stop all service threads and clear pending handlers.

Specified by:

close in interface AutoCloseable

Overrides:

close in class com.yahoo.bullet.pubsub.PubSubResponder