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