We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 534e099 commit 7344490Copy full SHA for 7344490
1 file changed
proteus-client/src/main/java/io/netifi/proteus/DefaultProteusBrokerService.java
@@ -102,8 +102,8 @@ public DefaultProteusBrokerService(
102
this.requestHandlingRSocket = new UnwrappingRSocket(requestHandlingRSocket);
103
this.group = group;
104
this.destinationNameFactory = destinationNameFactory;
105
- this.members = new ArrayList<>();
106
- this.suppliers = new ArrayList<>();
+ this.members = Collections.synchronizedList(new ArrayList<>());
+ this.suppliers = Collections.synchronizedList(new ArrayList<>());
107
this.clientTransportFactory = clientTransportFactory;
108
this.poolSize = poolSize;
109
this.selectRefresh = poolSize / 2;
0 commit comments