bobocep.cep.action.handler.BoboActionHandler

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

Bases: abc.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() → Optional[bobocep.cep.action.handler.BoboHandlerResponse][source]

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

handle(action: bobocep.cep.action.action.BoboAction, event: bobocep.cep.event.complex.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.