Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-03-03 07:49:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-4814 Improve synchronization on SimpleAddressManager::getDirectBindings

Browse Source
This commit is contained in:
Clebert Suconic 2024-06-20 09:38:53 -04:00 committed by clebertsuconic
parent 229afee380
commit dba753bffc
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/SimpleAddressManager.java
View File

@ -178,7 +178,17 @@ public class SimpleAddressManager implements AddressManager {
@Override
public Collection<Binding> getDirectBindings(final SimpleString address) throws Exception {
SimpleString realAddress = CompositeAddress.extractAddressName(address);
return new ArrayList<>(directBindingMap.getOrDefault(realAddress, Collections.emptyList()));
ArrayList<Binding> outputList = new ArrayList<>();
directBindingMap.compute(realAddress, (key, bindings) -> {
if (bindings != null) {
outputList.addAll(bindings);
}
return bindings;
});
return Collections.unmodifiableCollection(outputList);
}
@Override