Fix immutable list for Mqttv5MDChAdapter.subscriptions

spring-projects · Jan 30, 2024 · 25874b3 · 25874b3
1 parent 19ad0dc
commit 25874b3
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/...a/org/springframework/integration/mqtt/inbound/Mqttv5PahoMessageDrivenChannelAdapter.java b/...a/org/springframework/integration/mqtt/inbound/Mqttv5PahoMessageDrivenChannelAdapter.java
@@ -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 Mqttv5PahoMessageDrivenChannelAdapter(MqttConnectionOptions connectionOpt
 
 		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 Mqttv5PahoMessageDrivenChannelAdapter(ClientManager<IMqttAsyncClient, Mqt
 			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);
 	}
 
 	/**