This is an automated email from the ASF dual-hosted git repository.
mxsm 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 e66109c94 [ISSUE #4193]Do some code optimization. (#4452)
e66109c94 is described below
commit e66109c94bea6ae0438d8d12d9d527efa6b05b2f
Author: yanrongzhen <[email protected]>
AuthorDate: Tue Sep 19 21:20:22 2023 +0800
[ISSUE #4193]Do some code optimization. (#4452)
---
.../runtime/core/protocol/grpc/consumer/ConsumerManager.java | 12 +++++-------
1 file changed, 5 insertions(+), 7 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 cbe61e22d..4cf219424 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
@@ -47,15 +47,15 @@ import lombok.extern.slf4j.Slf4j;
@Slf4j
public class ConsumerManager {
- private final transient EventMeshGrpcServer eventMeshGrpcServer;
+ private final EventMeshGrpcServer eventMeshGrpcServer;
- private final transient ScheduledExecutorService scheduledExecutorService
= Executors.newSingleThreadScheduledExecutor();
+ private final ScheduledExecutorService scheduledExecutorService =
Executors.newSingleThreadScheduledExecutor();
// key: ConsumerGroup
- private final transient Map<String, List<ConsumerGroupClient>> clientTable
= new ConcurrentHashMap<>();
+ private final Map<String, List<ConsumerGroupClient>> clientTable = new
ConcurrentHashMap<>();
// key: ConsumerGroup
- private final transient Map<String, EventMeshConsumer> consumerTable = new
ConcurrentHashMap<>();
+ private final Map<String, EventMeshConsumer> consumerTable = new
ConcurrentHashMap<>();
public ConsumerManager(final EventMeshGrpcServer eventMeshGrpcServer) {
this.eventMeshGrpcServer = eventMeshGrpcServer;
@@ -210,9 +210,7 @@ public class ConsumerManager {
}
final List<ConsumerGroupClient> clientList = new ArrayList<>();
- clientTable.values().forEach(clients -> {
- clientList.addAll(clients);
- });
+ clientTable.values().forEach(clientList::addAll);
if (log.isDebugEnabled()) {
log.debug("total number of ConsumerGroupClients: {}",
clientList.size());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
