From 45e7f31b78be2d6195b1fca8194090e90d048776 Mon Sep 17 00:00:00 2001
From: EnduIf <5352931+EnduIf@users.noreply.github.com>
Date: Wed, 16 Jul 2025 22:52:29 +0200
Subject: [PATCH] fixed declaring exchange not setting arguments

---
 pkg/rabbitmqamqp/amqp_exchange.go   | 4 ++++
 pkg/rabbitmqamqp/amqp_management.go | 1 +
 2 files changed, 5 insertions(+)

diff --git a/pkg/rabbitmqamqp/amqp_exchange.go b/pkg/rabbitmqamqp/amqp_exchange.go
index 36c25af..943b4cf 100644
--- a/pkg/rabbitmqamqp/amqp_exchange.go
+++ b/pkg/rabbitmqamqp/amqp_exchange.go
@@ -61,6 +61,10 @@ func (e *AmqpExchange) AutoDelete(isAutoDelete bool) {
 	e.isAutoDelete = isAutoDelete
 }
 
+func (e *AmqpExchange) Arguments(arguments map[string]any) {
+	e.arguments = arguments
+}
+
 func (e *AmqpExchange) IsAutoDelete() bool {
 	return e.isAutoDelete
 }
diff --git a/pkg/rabbitmqamqp/amqp_management.go b/pkg/rabbitmqamqp/amqp_management.go
index b3b9fda..a0860ea 100644
--- a/pkg/rabbitmqamqp/amqp_management.go
+++ b/pkg/rabbitmqamqp/amqp_management.go
@@ -200,6 +200,7 @@ func (a *AmqpManagement) DeclareExchange(ctx context.Context, exchangeSpecificat
 	exchange := newAmqpExchange(a, exchangeSpecification.name())
 	exchange.AutoDelete(exchangeSpecification.isAutoDelete())
 	exchange.ExchangeType(exchangeSpecification.exchangeType())
+	exchange.Arguments(exchangeSpecification.arguments())
 	return exchange.Declare(ctx)
 }