happyly.listening.listener

Description

BaseListener and its subclasses. Listener is a form of Executor which is able to run pipeline by an event coming from a subscription.

Classes

BaseListener(subscriber, handler, deserializer)

Listener is a form of Executor which is able to run pipeline by an event coming from a subscription.

EarlyAckListener(subscriber, handler, …[, …])

Acknowledge-aware BaseListener, which performs ack() right after on_received() callback is finished.

LateAckListener(subscriber, handler, …[, …])

Acknowledge-aware listener, which performs ack() at the very end of pipeline.

ListenerWithAck(subscriber, handler, …[, …])

Acknowledge-aware listener.