module

JoobQ::EventSink

Observer interface: implement to receive lifecycle events.

Instance methods

publish(event : Event) : Nil

publish_all(events : Array(Event)) : Nil

Sinks that can deliver in bulk (e.g. one pipelined round trip) override this.