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

Fix concurrency in test case

Browse Source
This commit is contained in:
Gary Russell
2019-01-25 12:47:13 -05:00
parent a44235c189
commit 2e962225c2
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-rabbit/src/test/java/org/springframework/amqp/rabbit/core/RabbitTemplateIntegrationTests.java
View File

@@ -47,11 +47,11 @@ import java.io.UnsupportedEncodingException;
import java.lang.reflect.Field;
import java.util.Arrays;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Properties;
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
@@ -1246,7 +1246,7 @@ public class RabbitTemplateIntegrationTests {
int count = 10;
final Map<Double, Object> results = new HashMap<Double, Object>();
final Map<Double, Object> results = new ConcurrentHashMap<Double, Object>();
ExecutorService executor = Executors.newFixedThreadPool(10);