SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Polishing Map initialization in new code

Browse Source 
Resolves #255
This commit is contained in:
Oleg Zhurakousky
2019-07-08 17:47:24 +02:00
parent fe09a8bcbe
commit 43d2a9caa1
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-cloud-stream-binder-rabbit-core/src/main/java/org/springframework/cloud/stream/binder/rabbit/provisioning/RabbitExchangeQueueProvisioner.java
View File

@@ -292,8 +292,7 @@ public class RabbitExchangeQueueProvisioner
if (routingKey == null) {
routingKey = "#";
}
Map<String, Object> arguments = new HashMap<>();
arguments.putAll(extendedProperties.getQueueBindingArguments());
Map<String, Object> 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<String, Object> arguments = new HashMap<>();
arguments.putAll(properties.getDlqBindingArguments());
Map<String, Object> arguments = new HashMap<>(properties.getDlqBindingArguments());
Binding dlqBinding = new Binding(dlq.getName(), DestinationType.QUEUE,
dlxName, properties.getDlqDeadLetterRoutingKey() == null ? routingKey
: properties.getDeadLetterRoutingKey(),