File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
spring-kafka/src/main/java/org/springframework/kafka/listener/adapter Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change 2121import java .lang .reflect .Parameter ;
2222import java .util .ArrayList ;
2323import java .util .Arrays ;
24- import java .util .HashMap ;
2524import java .util .List ;
2625import java .util .Map ;
2726import 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
You can’t perform that action at this time.
0 commit comments