-record(notification, {
    channel :: binary(),
    payload :: binary(),
    pg_pid :: integer()
}).