Skip to content

Commit f045844

Browse files
garyrussellartembilan
authored andcommitted
GH-1952: Fix Possible NPE
Resolves #1952 Since maps are built on the fly, maps need to support concurrency. **cherry-pick back to 2.5.x**
1 parent 6cbcad8 commit f045844

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/DelegatingInvocableHandler.java

+2-3
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121
import java.lang.reflect.Parameter;
2222
import java.util.ArrayList;
2323
import java.util.Arrays;
24-
import java.util.HashMap;
2524
import java.util.List;
2625
import java.util.Map;
2726
import java.util.concurrent.ConcurrentHashMap;
@@ -72,9 +71,9 @@ public class DelegatingInvocableHandler {
7271

7372
private final InvocableHandlerMethod defaultHandler;
7473

75-
private final Map<InvocableHandlerMethod, Expression> handlerSendTo = new HashMap<>();
74+
private final Map<InvocableHandlerMethod, Expression> handlerSendTo = new ConcurrentHashMap<>();
7675

77-
private final Map<InvocableHandlerMethod, Boolean> handlerReturnsMessage = new HashMap<>();
76+
private final Map<InvocableHandlerMethod, Boolean> handlerReturnsMessage = new ConcurrentHashMap<>();
7877

7978
private final Object bean;
8079

0 commit comments

Comments
 (0)