From abfa54bf8a87a6703df43f571a559555be81bc1c Mon Sep 17 00:00:00 2001
From: Artur Souza <artursouza.ms@outlook.com>
Date: Fri, 17 Sep 2021 14:49:50 -0700
Subject: [PATCH] Fix PubSubIT due to race in map.

---
 .../test/java/io/dapr/it/pubsub/http/SubscriberController.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/SubscriberController.java b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/SubscriberController.java
index cb9d3a2f9c..87bdf98728 100644
--- a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/SubscriberController.java
+++ b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/SubscriberController.java
@@ -27,7 +27,7 @@
 @RestController
 public class SubscriberController {
 
-  private final Map<String, List<CloudEvent<?>>> messagesByTopic = new HashMap<>();
+  private final Map<String, List<CloudEvent<?>>> messagesByTopic = Collections.synchronizedMap(new HashMap<>());
 
   @GetMapping(path = "/messages/{topic}")
   public List<CloudEvent<?>> getMessagesByTopic(@PathVariable("topic") String topic) {