From 43d2a9caa166580c503ad50013373a1f77058154 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Mon, 8 Jul 2019 17:47:24 +0200 Subject: [PATCH] Polishing Map initialization in new code Resolves #255 --- .../rabbit/provisioning/RabbitExchangeQueueProvisioner.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) 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(),