Skip to content

Commit c7f6148

Browse files
committed
Fix concurrency in test case
1 parent 75b552f commit c7f6148

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -47,11 +47,11 @@
4747
import java.lang.reflect.Field;
4848
import java.util.Arrays;
4949
import java.util.Collection;
50-
import java.util.HashMap;
5150
import java.util.List;
5251
import java.util.Map;
5352
import java.util.Properties;
5453
import java.util.UUID;
54+
import java.util.concurrent.ConcurrentHashMap;
5555
import java.util.concurrent.CountDownLatch;
5656
import java.util.concurrent.ExecutorService;
5757
import java.util.concurrent.Executors;
@@ -1252,7 +1252,7 @@ public void testSymmetricalReceiveAndReply() throws InterruptedException, Unsupp
12521252

12531253
int count = 10;
12541254

1255-
final Map<Double, Object> results = new HashMap<Double, Object>();
1255+
final Map<Double, Object> results = new ConcurrentHashMap<Double, Object>();
12561256

12571257
ExecutorService executor = Executors.newFixedThreadPool(10);
12581258

0 commit comments

Comments
 (0)