From 87019dc08714bdd1bed452567e44f1ccdad46477 Mon Sep 17 00:00:00 2001 From: Thorsten Scheckenbach Date: Wed, 29 Sep 2021 10:04:24 +0200 Subject: [PATCH 1/3] Add function to add QueueArgs to consume options --- consume_options.go | 7 +++++++ 1 file changed, 7 insertions(+) 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 + } +} From 405ffbd5f5e192ad9b6d5a5571756a69269256a5 Mon Sep 17 00:00:00 2001 From: Thorsten Scheckenbach Date: Wed, 29 Sep 2021 10:31:07 +0200 Subject: [PATCH 2/3] Update module path --- go.mod | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/go.mod b/go.mod index ab9741a..5909a2e 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/wagslane/go-rabbitmq +module github.com/tscheckenbach/go-rabbitmq go 1.16 From fd1a3feb6a5bd668cd1611b97c2350da1979d01f Mon Sep 17 00:00:00 2001 From: Thorsten Scheckenbach Date: Wed, 29 Sep 2021 10:31:58 +0200 Subject: [PATCH 3/3] Revert "Update module path" This reverts commit 405ffbd5f5e192ad9b6d5a5571756a69269256a5. --- go.mod | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/go.mod b/go.mod index 5909a2e..ab9741a 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/tscheckenbach/go-rabbitmq +module github.com/wagslane/go-rabbitmq go 1.16