Skip to content

Commit 0803220

Browse files
garyrussellartembilan
authored andcommitted
INT-4441: Fix ACMH Concurrency Problem
JIRA: https://jira.spring.io/browse/INT-4441 Possible concurrent updates to `AbstractCorrelatingMessageHandler.groupIds` and `expireGroupScheduledFutures`. (cherry picked from commit f9d5198) # Conflicts: # spring-integration-core/src/main/java/org/springframework/integration/aggregator/AbstractCorrelatingMessageHandler.java
1 parent 5919613 commit 0803220

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

spring-integration-core/src/main/java/org/springframework/integration/aggregator/AbstractCorrelatingMessageHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,10 +20,10 @@
2020
import java.util.Collections;
2121
import java.util.Comparator;
2222
import java.util.Date;
23-
import java.util.HashMap;
2423
import java.util.List;
2524
import java.util.Map;
2625
import java.util.UUID;
26+
import java.util.concurrent.ConcurrentHashMap;
2727
import java.util.concurrent.ScheduledFuture;
2828
import java.util.concurrent.locks.Lock;
2929

@@ -92,7 +92,7 @@ public abstract class AbstractCorrelatingMessageHandler extends AbstractMessageP
9292

9393
private final Comparator<Message<?>> sequenceNumberComparator = new SequenceNumberComparator();
9494

95-
private final Map<UUID, ScheduledFuture<?>> expireGroupScheduledFutures = new HashMap<UUID, ScheduledFuture<?>>();
95+
private final Map<UUID, ScheduledFuture<?>> expireGroupScheduledFutures = new ConcurrentHashMap<UUID, ScheduledFuture<?>>();
9696

9797
private final MessageGroupProcessor outputProcessor;
9898

0 commit comments

Comments
 (0)