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 0a2cf8efa3
commit 1fc6fc1f0d
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

@@ -46,11 +46,11 @@ import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.lang.reflect.Field;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;
import java.util.concurrent.Callable;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
@@ -1307,7 +1307,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);