This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new e4ec6fd3e [ISSUE #4141] Fix the GRPC subscribe error (#4143)
e4ec6fd3e is described below
commit e4ec6fd3eb7cc85e8a322012dc2117a8b7a48ac5
Author: 枫桥 <[email protected]>
AuthorDate: Sun Jun 25 09:56:06 2023 +0800
[ISSUE #4141] Fix the GRPC subscribe error (#4143)
Co-authored-by: yiqf <yiqf>
---
.../eventmesh/runtime/core/protocol/grpc/consumer/ConsumerManager.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/ConsumerManager.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/ConsumerManager.java
index f3cb6b639..1260a6bc6 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/ConsumerManager.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/ConsumerManager.java
@@ -90,8 +90,7 @@ public class ConsumerManager {
}
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) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
