org.alfresco.bm.driver.event

Class EventController

java.lang.Object

org.alfresco.bm.driver.event.EventController

All Implemented Interfaces:

Runnable, LifecycleListener, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

public class EventController
extends Object
implements LifecycleListener, org.springframework.context.ApplicationContextAware, Runnable

A master controlling thread that ensures that:

• reads events from the queue
• checks out threads to process events
• monitors event processors
• records event executions
• handles exceptions e.g. events that take too long to process

Calls from the LifecycleListener control the execution phases and, when the events run out, the application context is notified to shut down.

Since:

1.0

Author:

Derek Hulley

Constructor Summary

Constructors

Constructor and Description
EventController(String driverId, String testRunFqn, EventService eventService, EventProducerRegistry eventProducers, EventProcessorRegistry eventProcessors, ResultService resultService, SessionService sessionService, TestRunLogService logService, int threadCount) Construct the controller

Method Summary

Modifier and Type	Method and Description
void	run()
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext) Record the application context for shutdown once processing has finished
void	setAssignedEventGracePeriod(int assignedEventGracePeriod) Override the default time that an event can be available on the queue for a specific driver before any other driver can pick it up.
void	setDriverIds(String[] driverIds) Update the list of driver IDs in use.
void	setEventsPerSecondPerThread(int eventsPerSecondPerThread) Override the maximum number of events that can be processed per second per thread.
void	start() Kick the thread off
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

EventController

public EventController(String driverId,
                       String testRunFqn,
                       EventService eventService,
                       EventProducerRegistry eventProducers,
                       EventProcessorRegistry eventProcessors,
                       ResultService resultService,
                       SessionService sessionService,
                       TestRunLogService logService,
                       int threadCount)

Construct the controller

Parameters:

driverId - the ID of the driver controlling the events

testRunFqn - the fully qualified name of the test run

testDAO - the test DAO for accessing low level data

testRunId - the ID of the test run being controlled

eventService - the source of events that will be pushed for execution

eventProducers - the registry of producers of events

eventProcessors - the registry of processors for events

resultService - the service used to store and retrieve event results

sessionService - the service to carry session IDs between events

logService - the service to record log messages for the end user

threadCount - the number of threads available to the processor

Method Detail

setEventsPerSecondPerThread

public void setEventsPerSecondPerThread(int eventsPerSecondPerThread)

Override the maximum number of events that can be processed per second per thread. This represents a maximum; lower volumes will be processed at the required rate. Ensure there are enough threads available to process events at the anticipated rate or change this value.

setAssignedEventGracePeriod

public void setAssignedEventGracePeriod(int assignedEventGracePeriod)

Override the default time that an event can be available on the queue for a specific driver before any other driver can pick it up.

setDriverIds

public void setDriverIds(String[] driverIds)

Update the list of driver IDs in use. This list can change at run time.

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Record the application context for shutdown once processing has finished

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

start

public void start()

Kick the thread off

Specified by:

start in interface LifecycleListener

stop

public void stop()

Specified by:

stop in interface LifecycleListener

run

public void run()

Specified by:

run in interface Runnable