-record(delivery, {
    topic :: binary(),
    subscriber_id :: binary(),
    message :: any()
}).