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 510257b49 [ISSUE #3728] Replace this "Map.get()" and condition with a
call to "Map.computeIfAbsent()". [ConsumerManager] (#3736)
510257b49 is described below
commit 510257b493ff233a6d8f7bb5c8942309c9f7cb0d
Author: Harshitha Sudhakar
<[email protected]>
AuthorDate: Fri May 5 07:16:56 2023 +0530
[ISSUE #3728] Replace this "Map.get()" and condition with a call to
"Map.computeIfAbsent()". [ConsumerManager] (#3736)
* Update ConsumerManager.java
Replaced "Map.get()" and condition with a call to "Map.computeIfAbsent()"
at line 92.
* Update ConsumerManager.java
---
.../eventmesh/runtime/core/protocol/grpc/consumer/ConsumerManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 4e1b9a86d..4fd701e92 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,7 +90,7 @@ public class ConsumerManager {
public EventMeshConsumer getEventMeshConsumer(final String consumerGroup) {
return consumerTable.computeIfAbsent(consumerGroup, key ->
- consumerTable.put(consumerGroup,
new EventMeshConsumer(eventMeshGrpcServer, consumerGroup)));
+ consumerTable.put(consumerGroup, new
EventMeshConsumer(eventMeshGrpcServer, consumerGroup)));
}
public synchronized void registerClient(final ConsumerGroupClient
newClient) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
