Protect against concurrent list updates in Pulsar samples

See gh-34763

Author: philwebb

spring-boot-tests/spring-boot-smoke-tests/spring-boot-smoke-test-pulsar-reactive/src/main/java/smoketest/pulsar/reactive/SampleMessageConsumer.java

@@ -16,8 +16,8 @@
 
 package smoketest.pulsar.reactive;
 
-import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.CopyOnWriteArrayList;
 
 import reactor.core.publisher.Mono;
 
@@ -27,7 +27,7 @@
 @Component
 class SampleMessageConsumer {
 
-	private List<SampleMessage> consumed = new ArrayList<>();
+	private List<SampleMessage> consumed = new CopyOnWriteArrayList<>();
 
 	List<SampleMessage> getConsumed() {
 		return this.consumed;

spring-boot-tests/spring-boot-smoke-tests/spring-boot-smoke-test-pulsar/src/main/java/smoketest/pulsar/SampleMessageConsumer.java

@@ -16,16 +16,16 @@
 
 package smoketest.pulsar;
 
-import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.CopyOnWriteArrayList;
 
 import org.springframework.pulsar.annotation.PulsarListener;
 import org.springframework.stereotype.Component;
 
 @Component
 class SampleMessageConsumer {
 
-	private List<SampleMessage> consumed = new ArrayList<>();
+	private List<SampleMessage> consumed = new CopyOnWriteArrayList<>();
 
 	List<SampleMessage> getConsumed() {
 		return this.consumed;