diff --git a/spring-cloud-stream-binder-rabbit-core/src/main/java/org/springframework/cloud/stream/binder/rabbit/provisioning/RabbitExchangeQueueProvisioner.java b/spring-cloud-stream-binder-rabbit-core/src/main/java/org/springframework/cloud/stream/binder/rabbit/provisioning/RabbitExchangeQueueProvisioner.java index 27d2e9862..279b70adc 100644 --- a/spring-cloud-stream-binder-rabbit-core/src/main/java/org/springframework/cloud/stream/binder/rabbit/provisioning/RabbitExchangeQueueProvisioner.java +++ b/spring-cloud-stream-binder-rabbit-core/src/main/java/org/springframework/cloud/stream/binder/rabbit/provisioning/RabbitExchangeQueueProvisioner.java @@ -292,8 +292,7 @@ public class RabbitExchangeQueueProvisioner if (routingKey == null) { routingKey = "#"; } - Map arguments = new HashMap<>(); - arguments.putAll(extendedProperties.getQueueBindingArguments()); + Map arguments = new HashMap<>(extendedProperties.getQueueBindingArguments()); if (exchange instanceof TopicExchange) { Binding binding = BindingBuilder.bind(queue).to((TopicExchange) exchange) .with(routingKey); @@ -355,8 +354,7 @@ public class RabbitExchangeQueueProvisioner properties.getDeadLetterExchangeType()).durable(true) .build()); } - Map arguments = new HashMap<>(); - arguments.putAll(properties.getDlqBindingArguments()); + Map arguments = new HashMap<>(properties.getDlqBindingArguments()); Binding dlqBinding = new Binding(dlq.getName(), DestinationType.QUEUE, dlxName, properties.getDlqDeadLetterRoutingKey() == null ? routingKey : properties.getDeadLetterRoutingKey(),