org.apache.oozie.service

Class EventHandlerService

java.lang.Object

org.apache.oozie.service.EventHandlerService

All Implemented Interfaces:

Service

public class EventHandlerService
extends Object
implements Service

Service class that handles the events system - creating events queue, managing configured properties and managing and invoking various event listeners via worker threads

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	EventHandlerService.EventWorker

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONF_BATCH_SIZE
static String	CONF_EVENT_QUEUE
static String	CONF_FILTER_APP_TYPES
static String	CONF_LISTENERS
static String	CONF_PREFIX
static String	CONF_QUEUE_SIZE
static String	CONF_WORKER_INTERVAL
static String	CONF_WORKER_THREADS

Fields inherited from interface org.apache.oozie.service.Service

DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
EventHandlerService()

Method Summary

Modifier and Type	Method and Description
void	addEventListener(Object listener, org.apache.hadoop.conf.Configuration conf, String name)
void	destroy() Destroy the service.
Set<String>	getAppTypes()
EventQueue	getEventQueue()
Class<? extends Service>	getInterface() Return the public interface of the service.
void	init(Services services) Initialize the service.
static boolean	isEnabled()
boolean	isSupportedApptype(String appType)
String	listEventListeners()
void	queueEvent(Event event)
void	setAppTypes(Set<String> types)

Methods inherited from class java.lang.Object

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

Field Detail

CONF_PREFIX

public static final String CONF_PREFIX

See Also:

Constant Field Values

CONF_QUEUE_SIZE

public static final String CONF_QUEUE_SIZE

See Also:

Constant Field Values

CONF_EVENT_QUEUE

public static final String CONF_EVENT_QUEUE

See Also:

Constant Field Values

CONF_LISTENERS

public static final String CONF_LISTENERS

See Also:

Constant Field Values

CONF_FILTER_APP_TYPES

public static final String CONF_FILTER_APP_TYPES

See Also:

Constant Field Values

CONF_BATCH_SIZE

public static final String CONF_BATCH_SIZE

See Also:

Constant Field Values

CONF_WORKER_THREADS

public static final String CONF_WORKER_THREADS

See Also:

Constant Field Values

CONF_WORKER_INTERVAL

public static final String CONF_WORKER_INTERVAL

See Also:

Constant Field Values

Constructor Detail

EventHandlerService

public EventHandlerService()

Method Detail

init

public void init(Services services)
          throws ServiceException

Description copied from interface: Service

Initialize the service.

Invoked by the Service singleton at start up time.

Specified by:

init in interface Service

Parameters:

services - services singleton initializing the service.

Throws:

ServiceException - thrown if the service could not initialize.

addEventListener

public void addEventListener(Object listener,
                             org.apache.hadoop.conf.Configuration conf,
                             String name)
                      throws Exception

Throws:

Exception

isEnabled

public static boolean isEnabled()

destroy

public void destroy()

Description copied from interface: Service

Destroy the service.

Invoked by the Service singleton at shutdown time.

Specified by:

destroy in interface Service

getInterface

public Class<? extends Service> getInterface()

Description copied from interface: Service

Return the public interface of the service.

Services are retrieved by its public interface. Specializations of services must return the public interface.

Specified by:

getInterface in interface Service

Returns:

the interface of the service.

isSupportedApptype

public boolean isSupportedApptype(String appType)

setAppTypes

public void setAppTypes(Set<String> types)

getAppTypes

public Set<String> getAppTypes()

listEventListeners

public String listEventListeners()

queueEvent

public void queueEvent(Event event)

getEventQueue

public EventQueue getEventQueue()