happyly.listening.listener.LateAckExecutor¶
-
class
happyly.listening.listener.
LateAckExecutor
(subscriber, handler, deserializer, serializer=<happyly.serialization.dummy.DummySerde object>, publisher=None)¶ Bases:
happyly.listening.listener.ExecutorWithAck
,typing.Generic
Acknowledge-aware listener, which performs
ack()
at the very end of pipeline.on_finished
(original_message, error)Callback which is called when pipeline finishes its execution.
-
on_finished
(original_message, error)¶ Callback which is called when pipeline finishes its execution. Is guaranteed to be called unless pipeline is stopped via StopPipeline.
-