Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix immutable list for Mqttv5MDChAdapter.subscriptions

Browse Source
This commit is contained in:
Artem Bilan
2024-01-30 16:44:08 -05:00
parent 19ad0dc02e
commit 25874b3ab9
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/inbound/Mqttv5PahoMessageDrivenChannelAdapter.java
View File

@@ -16,7 +16,9 @@
package org.springframework.integration.mqtt.inbound;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.concurrent.locks.Lock;
@@ -114,7 +116,8 @@ public class Mqttv5PahoMessageDrivenChannelAdapter
*/
public Mqttv5PahoMessageDrivenChannelAdapter(String url, String clientId, MqttSubscription... mqttSubscriptions) {
this(url, clientId, Arrays.stream(mqttSubscriptions).map(MqttSubscription::getTopic).toArray(String[]::new));
this.subscriptions = Arrays.asList(mqttSubscriptions);
this.subscriptions = new ArrayList<>();
Collections.addAll(this.subscriptions, mqttSubscriptions);
}
public Mqttv5PahoMessageDrivenChannelAdapter(String url, String clientId, String... topic) {
@@ -137,7 +140,8 @@ public class Mqttv5PahoMessageDrivenChannelAdapter
this(connectionOptions, clientId,
Arrays.stream(mqttSubscriptions).map(MqttSubscription::getTopic).toArray(String[]::new));
this.subscriptions = List.of(mqttSubscriptions);
this.subscriptions = new ArrayList<>();
Collections.addAll(this.subscriptions, mqttSubscriptions);
}
public Mqttv5PahoMessageDrivenChannelAdapter(MqttConnectionOptions connectionOptions, String clientId,
@@ -162,7 +166,8 @@ public class Mqttv5PahoMessageDrivenChannelAdapter
MqttSubscription... mqttSubscriptions) {
this(clientManager, Arrays.stream(mqttSubscriptions).map(MqttSubscription::getTopic).toArray(String[]::new));
this.subscriptions = List.of(mqttSubscriptions);
this.subscriptions = new ArrayList<>();
Collections.addAll(this.subscriptions, mqttSubscriptions);
}
/**