fixed declaring exchange not setting arguments

Author: EnduIf

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
 }

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)
 }