Package eu.rarogsoftware.rarog.platform.core.plugins.events

Class DefaultEventService

java.lang.Object

eu.rarogsoftware.rarog.platform.core.plugins.events.DefaultEventService

All Implemented Interfaces:

EventService

@Service
@ExportComponent
public class DefaultEventService
extends Object
implements EventService

Nested Class Summary

Nested classes/interfaces inherited from interface eu.rarogsoftware.rarog.platform.api.plugins.events.EventService

EventService.EventType

Field Summary

Fields

Modifier and Type	Field	Description
(package private) Map<Class<?>,List<eu.rarogsoftware.rarog.platform.core.plugins.events.DefaultEventService.EventConsumerRegistration>>	listeners

Constructor Summary

Constructors

Constructor	Description
DefaultEventService(TaskManager taskManager, MetricsService metricsService)
DefaultEventService(Clock clock, TaskManager taskManager, MetricsService metricsService)

Method Summary

Modifier and Type	Method	Description
void	publishAsyncEvent(Object event)	Publishes the event in an asynchronous manner.
void	publishParallelAsyncEvent(Object event)	Publishes the event in an asynchronous, parallel manner.
void	publishSyncEvent(Object event)	Publishes the event in a synchronous way, the method returns after all the handlers process the event.
void	publishSyncEventWithExceptions(Object event)	Publishes the event in a synchronous way, the method returns after all the handlers process the event.
void	registerListener(EventListener listener)	Registers all EventHandlers from passed object.
void	unregisterListener(EventListener listener)	Unregisters all EventHandlers from passed object.

Methods inherited from class java.lang.Object

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

Methods inherited from interface eu.rarogsoftware.rarog.platform.api.plugins.events.EventService

publishEvent

Field Details

listeners

Map<Class<?>,List<eu.rarogsoftware.rarog.platform.core.plugins.events.DefaultEventService.EventConsumerRegistration>> listeners

Constructor Details

DefaultEventService

DefaultEventService(Clock clock,
 TaskManager taskManager,
 MetricsService metricsService)

DefaultEventService

@Autowired
public DefaultEventService(TaskManager taskManager,
 MetricsService metricsService)

Method Details

publishSyncEvent

public void publishSyncEvent(Object event)

Description copied from interface: EventService

Publishes the event in a synchronous way, the method returns after all the handlers process the event. Swallows the exceptions in listeners

Specified by:

publishSyncEvent in interface EventService

Parameters:

event - Event to be published.

publishSyncEventWithExceptions

public void publishSyncEventWithExceptions(Object event)

Description copied from interface: EventService

Publishes the event in a synchronous way, the method returns after all the handlers process the event. Rethrows the exceptions in listeners as EventDeliveryFailedException

Specified by:

publishSyncEventWithExceptions in interface EventService

Parameters:

event - Event to be published.

publishAsyncEvent

public void publishAsyncEvent(Object event)

Description copied from interface: EventService

Publishes the event in an asynchronous manner. The method returns just after single task of invoking all handlers sequentially is submitted to TaskManager Swallows the exceptions in listeners

Specified by:

publishAsyncEvent in interface EventService

Parameters:

event - Event to be published.

publishParallelAsyncEvent

public void publishParallelAsyncEvent(Object event)

Description copied from interface: EventService

Publishes the event in an asynchronous, parallel manner. The method submits single task per event handler to TaskManager and returns. Events are processed in parallel if there are available threads in TaskManager's thread pool. Swallows the exceptions in listeners

Specified by:

publishParallelAsyncEvent in interface EventService

Parameters:

event - Event to be published.

registerListener

public void registerListener(EventListener listener)

Description copied from interface: EventService

Registers all EventHandlers from passed object. If handlers with more than one parameter are found, this fact is logged and the method is skipped but processing is not stopped. If the passed EventListener doesn't have any valid handlers, IllegalArgumentException is thrown.

Specified by:

registerListener in interface EventService

Parameters:

listener - Event Listener class which defines EventHandler methods.

unregisterListener

public void unregisterListener(EventListener listener)

Description copied from interface: EventService

Unregisters all EventHandlers from passed object.

Specified by:

unregisterListener in interface EventService

Parameters:

listener - Event Listener class which defines EventHandler methods.