diff --git a/consume_options.go b/consume_options.go index e0f8a3b..fd226f6 100644 --- a/consume_options.go +++ b/consume_options.go @@ -221,3 +221,10 @@ func WithConsumeOptionsConsumerExclusive(options *ConsumeOptions) { func WithConsumeOptionsConsumerNoWait(options *ConsumeOptions) { options.ConsumerNoWait = true } + +// WithConsumeOptionsQueueArgs returns a function that sets the queue arguments +func WithConsumeOptionsQueueArgs(args Table) func(*ConsumeOptions) { + return func(options *ConsumeOptions) { + options.QueueArgs = args + } +}