Consumers¶

class Consumer(func, logger=<RootLogger root (DEBUG)>)[source]¶

Bases: IConsumer

Parameters:

func (Callable[[Event], Any])
logger (Logger)

consume(event)[source]¶

Consume an event with consumer function

Parameters:: event (Event) – Event to consume
Returns:: None
Return type:: None