happyly.listening.listener.ListenerWithAck¶
-
class
happyly.listening.listener.
ListenerWithAck
(subscriber, handler, deserializer, serializer=<happyly.serialization.dummy.DummySerde object>, publisher=None)¶ Bases:
happyly.listening.listener.BaseListener
,typing.Generic
Acknowledge-aware listener. Defines
ListenerWithAck.ack()
method. SubclassListenerWithAck
and specify when to ack by overriding the corresponding callbacks.ack
(message)Acknowledge the message using implementation from subscriber, then log success.
on_acknowledged
(message)Callback which is called write after message was acknowledged.