fixed a CME issue during stopping inbox service

popduke · popduke · commit d906db3aa610 · 2024-09-14T18:07:43.000+08:00
diff --git a/bifromq-inbox/bifromq-inbox-server/src/main/java/com/baidu/bifromq/inbox/server/InboxFetcherRegistry.java b/bifromq-inbox/bifromq-inbox-server/src/main/java/com/baidu/bifromq/inbox/server/InboxFetcherRegistry.java
@@ -32,7 +32,7 @@ public final class InboxFetcherRegistry implements IInboxFetcherRegistry {
     public void reg(IInboxFetcher fetcher) {
         fetchers.compute(fetcher.tenantId(), (key, val) -> {
             if (val == null) {
-                val = new HashMap<>();
+                val = new ConcurrentHashMap<>();
             }
             IInboxFetcher prevFetcher = val.computeIfAbsent(fetcher.delivererKey(), k -> new ConcurrentHashMap<>())
                 .put(fetcher.id(), fetcher);

Original file line number	Diff line number	Diff line change
`@@ -32,7 +32,7 @@ public final class InboxFetcherRegistry implements IInboxFetcherRegistry {`
`32`	`32`	`public void reg(IInboxFetcher fetcher) {`
`33`	`33`	`fetchers.compute(fetcher.tenantId(), (key, val) -> {`
`34`	`34`	`if (val == null) {`
`35`		`- val = new HashMap<>();`
	`35`	`+ val = new ConcurrentHashMap<>();`
`36`	`36`	`}`
`37`	`37`	`IInboxFetcher prevFetcher = val.computeIfAbsent(fetcher.delivererKey(), k -> new ConcurrentHashMap<>())`
`38`	`38`	`.put(fetcher.id(), fetcher);`