org.graylog.events.processor

Class EventDefinitionHandler

java.lang.Object

org.graylog.events.processor.EventDefinitionHandler

public class EventDefinitionHandler
extends Object

Handles event definitions and creates scheduler job definitions and job triggers. Caveat: These handlers modify different database documents without using any transactions. That means we can run into concurrency issues and partial operations. TODO: Make use of transactions once our database library supports it

Constructor Summary

Constructors

Constructor and Description
EventDefinitionHandler(DBEventDefinitionService eventDefinitionService, DBJobDefinitionService jobDefinitionService, DBJobTriggerService jobTriggerService, JobSchedulerClock clock)

Method Summary

Modifier and Type	Method and Description
EventDefinitionDto	create(EventDefinitionDto unsavedDto) Creates a new event definition and a corresponding scheduler job definition and trigger.
boolean	delete(String dtoId) Deletes an existing event definition and its corresponding scheduler job definition and trigger.
EventDefinitionDto	update(EventDefinitionDto updatedDto) Updates an existing event definition and its corresponding scheduler job definition and trigger.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventDefinitionHandler

@Inject
public EventDefinitionHandler(DBEventDefinitionService eventDefinitionService,
                                      DBJobDefinitionService jobDefinitionService,
                                      DBJobTriggerService jobTriggerService,
                                      JobSchedulerClock clock)

Method Detail

create

public EventDefinitionDto create(EventDefinitionDto unsavedDto)

Creates a new event definition and a corresponding scheduler job definition and trigger.

Parameters:

unsavedDto - the event definition to save

Returns:

the created event definition

update

public EventDefinitionDto update(EventDefinitionDto updatedDto)

Updates an existing event definition and its corresponding scheduler job definition and trigger.

Parameters:

updatedDto - the event definition to update

Returns:

the updated event definition

delete

public boolean delete(String dtoId)

Deletes an existing event definition and its corresponding scheduler job definition and trigger.

Parameters:

dtoId - the event definition to delete

Returns:

true if the event definition got deleted, false otherwise