From ee50a939938da233dd4491dd2f33feaf30b3608b Mon Sep 17 00:00:00 2001
From: Mohammad Fatemi <mr.smf8@gmail.com>
Date: Tue, 14 Oct 2025 12:58:05 +0330
Subject: [PATCH] Modify WithConsumerOptionQueueArgs behavior

---
 consumer_options.go | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/consumer_options.go b/consumer_options.go
index 9df77e1..c313df5 100644
--- a/consumer_options.go
+++ b/consumer_options.go
@@ -146,6 +146,19 @@ func WithConsumerOptionsQueueNoDeclare(options *ConsumerOptions) {
 
 // WithConsumerOptionsQueueArgs adds optional args to the queue
 func WithConsumerOptionsQueueArgs(args Table) func(*ConsumerOptions) {
+	return func(options *ConsumerOptions) {
+		if options.QueueOptions.Args != nil {
+			for k, v := range args {
+				options.QueueOptions.Args[k] = v
+			}
+		}
+
+		options.QueueOptions.Args = args
+	}
+}
+
+// WithConsumerOptionsQueueArgsOverride overrides all already set arguments
+func WithConsumerOptionsQueueArgsOverride(args Table) func(*ConsumerOptions) {
 	return func(options *ConsumerOptions) {
 		options.QueueOptions.Args = args
 	}