Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix JMS Outbound Gateway Concurrency

Browse Source 
JIRA: https://jira.spring.io/browse/INT-3885

Backport just the fix changing `replies` to a `ConcurrentHashMap`.
This commit is contained in:
Gary Russell
2016-01-20 17:22:28 -05:00
parent 5556821a4e
commit e53399afde
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsOutboundGateway.java
View File

@@ -131,7 +131,7 @@ public class JmsOutboundGateway extends AbstractReplyProducingMessageHandler imp
private final String gatewayCorrelation = UUID.randomUUID().toString();
private final Map<String, LinkedBlockingQueue<javax.jms.Message>> replies =
new HashMap<String, LinkedBlockingQueue<javax.jms.Message>>();
new ConcurrentHashMap<String, LinkedBlockingQueue<javax.jms.Message>>();
private final ConcurrentHashMap<String, TimedReply> earlyOrLateReplies =
new ConcurrentHashMap<String, JmsOutboundGateway.TimedReply>();