[ISSUE apache#4141] Fix the GRPC subscribe error

1404369980 · Jun 20, 2023 · c6d422a · c6d422a
1 parent 8843df2
commit c6d422a
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...c/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/ConsumerManager.java b/...c/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/ConsumerManager.java
@@ -90,8 +90,7 @@ public void shutdown() throws Exception {
     }
 
     public EventMeshConsumer getEventMeshConsumer(final String consumerGroup) {
-        return consumerTable.computeIfAbsent(consumerGroup, key ->
-            consumerTable.put(consumerGroup, new EventMeshConsumer(eventMeshGrpcServer, consumerGroup)));
+        return consumerTable.computeIfAbsent(consumerGroup, key -> new EventMeshConsumer(eventMeshGrpcServer, consumerGroup));
     }
 
     public synchronized void registerClient(final ConsumerGroupClient newClient) {