-record(queue_source, {
    name :: binary(),
    topic :: binary(),
    prefetch :: integer()
}).