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 489dd2eaa Update EventMeshGrpcMonitor.java
new a45e3dff4 Merge pull request #3664 from harshithasudhakar/patch-18
489dd2eaa is described below
commit 489dd2eaa5bb4051d0fd5b57e78c5fdb05d3d7bf
Author: Harshitha Sudhakar
<[email protected]>
AuthorDate: Sat Apr 8 10:28:27 2023 +0530
Update EventMeshGrpcMonitor.java
Included "final" in the lines 41, 42, 44, 46. Removed curly braces at line
61.
---
.../eventmesh/runtime/metrics/grpc/EventMeshGrpcMonitor.java | 12 +++++-------
1 file changed, 5 insertions(+), 7 deletions(-)
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/grpc/EventMeshGrpcMonitor.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/grpc/EventMeshGrpcMonitor.java
index fe9fca4bc..a6d5c3f3b 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/grpc/EventMeshGrpcMonitor.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/grpc/EventMeshGrpcMonitor.java
@@ -38,12 +38,12 @@ public class EventMeshGrpcMonitor {
private static final int SCHEDULE_THREAD_SIZE = 1;
private static final String THREAD_NAME_PREFIX =
"eventMesh-grpc-monitor-scheduler";
- private EventMeshGrpcServer eventMeshGrpcServer;
- private List<MetricsRegistry> metricsRegistries;
+ private final EventMeshGrpcServer eventMeshGrpcServer;
+ private final List<MetricsRegistry> metricsRegistries;
- private ScheduledExecutorService scheduler;
+ private final ScheduledExecutorService scheduler;
private ScheduledFuture<?> scheduleTask;
- private GrpcSummaryMetrics grpcSummaryMetrics;
+ private final GrpcSummaryMetrics grpcSummaryMetrics;
public EventMeshGrpcMonitor(EventMeshGrpcServer eventMeshGrpcServer,
List<MetricsRegistry> metricsRegistries) {
this.eventMeshGrpcServer =
Preconditions.checkNotNull(eventMeshGrpcServer);
@@ -58,9 +58,7 @@ public class EventMeshGrpcMonitor {
}
public void start() throws Exception {
- metricsRegistries.forEach(metricsRegistry -> {
- metricsRegistry.register(grpcSummaryMetrics);
- });
+ metricsRegistries.forEach(metricsRegistry ->
metricsRegistry.register(grpcSummaryMetrics));
// update tps metrics and clear counter
scheduleTask = scheduler.scheduleAtFixedRate(() -> {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
