bobocep.cep.action.handler.BoboActionHandler

class bobocep.cep.action.handler.BoboActionHandler(max_size: int = 0)[source]

Bases: ABC

An abstract action handler.

__init__(max_size: int = 0)[source]

Parameters:: max_size – Maximum queue size. Default: 0 (unbounded).

close() → None[source]: Close the handler.

get_handler_response() → BoboHandlerResponse | None[source]

Returns:: Action response from queue, or None if queue is empty.

handle(action: BoboAction, event: BoboEventComplex) → Any[source]

Handle an action.

Parameters:

action – The action to handle.
event – The complex event that caused the action to trigger.

Returns:

A return value from handling the action.

is_closed() → bool[source]

Returns:: True if handler is closed; False otherwise.

size() → int[source]

Returns:: The size of the handler queue.