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.

Parameters
  • original_message (Any) – Message as it has been received, without any deserialization

  • error (Optional[Exception]) – exception object which was raised or None