[incubator-eventmesh] branch master updated: [ISSUE #3489]Add @Override annotation for methods

[mytang0]

This is an automated email from the ASF dual-hosted git repository.

mytang0 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git


The following commit(s) were added to refs/heads/master by this push:
     new 714c4ceaf [ISSUE #3489]Add @Override annotation for methods
     new 754ce0e06 Merge pull request #3490 from mxsm/eventmesh-3489
714c4ceaf is described below

commit 714c4ceaf0e5e9c0ebb3ad9debc7920b083f2e60
Author: mxsm <ljbm...@gmail.com>
AuthorDate: Mon Mar 20 23:16:15 2023 +0800

    [ISSUE #3489]Add @Override annotation for methods
---
 .../eventmesh/runtime/core/protocol/grpc/service/ConsumerService.java  | 3 +++
 .../eventmesh/runtime/core/protocol/grpc/service/HeartbeatService.java | 1 +
 .../eventmesh/runtime/core/protocol/grpc/service/ProducerService.java  | 3 +++
 3 files changed, 7 insertions(+)

diff --git 
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ConsumerService.java
 
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ConsumerService.java
index 6d3be08a5..2329146b8 100644
--- 
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ConsumerService.java
+++ 
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ConsumerService.java
@@ -52,6 +52,7 @@ public class ConsumerService extends 
ConsumerServiceGrpc.ConsumerServiceImplBase
         this.replyThreadPoolExecutor = replyThreadPoolExecutor;
     }
 
+    @Override
     public void subscribe(Subscription request, StreamObserver<Response> 
responseObserver) {
         log.info("cmd={}|{}|client2eventMesh|from={}|to={}",
             "subscribe", EventMeshConstants.PROTOCOL_GRPC,
@@ -71,6 +72,7 @@ public class ConsumerService extends 
ConsumerServiceGrpc.ConsumerServiceImplBase
         });
     }
 
+    @Override
     public StreamObserver<Subscription> 
subscribeStream(StreamObserver<SimpleMessage> responseObserver) {
         EventEmitter<SimpleMessage> emitter = new 
EventEmitter<>(responseObserver);
 
@@ -145,6 +147,7 @@ public class ConsumerService extends 
ConsumerServiceGrpc.ConsumerServiceImplBase
             .build();
     }
 
+    @Override
     public void unsubscribe(Subscription request, StreamObserver<Response> 
responseObserver) {
         log.info("cmd={}|{}|client2eventMesh|from={}|to={}",
             "unsubscribe", EventMeshConstants.PROTOCOL_GRPC,
diff --git 
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/HeartbeatService.java
 
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/HeartbeatService.java
index 768ced2ec..0837e827a 100644
--- 
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/HeartbeatService.java
+++ 
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/HeartbeatService.java
@@ -45,6 +45,7 @@ public class HeartbeatService extends 
HeartbeatServiceGrpc.HeartbeatServiceImplB
         this.threadPoolExecutor = threadPoolExecutor;
     }
 
+    @Override
     public void heartbeat(Heartbeat request, StreamObserver<Response> 
responseObserver) {
         log.info("cmd={}|{}|client2eventMesh|from={}|to={}",
             "heartbeat", EventMeshConstants.PROTOCOL_GRPC, 
request.getHeader().getIp(),
diff --git 
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ProducerService.java
 
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ProducerService.java
index 9513c14b6..f9fcd02a5 100644
--- 
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ProducerService.java
+++ 
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ProducerService.java
@@ -53,6 +53,7 @@ public class ProducerService extends 
PublisherServiceGrpc.PublisherServiceImplBa
         this.threadPoolExecutor = threadPoolExecutor;
     }
 
+    @Override
     public void publish(SimpleMessage request, StreamObserver<Response> 
responseObserver) {
         cmdLogger.info("cmd={}|{}|client2eventMesh|from={}|to={}", 
"AsyncPublish",
             EventMeshConstants.PROTOCOL_GRPC, request.getHeader().getIp(),
@@ -72,6 +73,7 @@ public class ProducerService extends 
PublisherServiceGrpc.PublisherServiceImplBa
         });
     }
 
+    @Override
     public void requestReply(SimpleMessage request, 
StreamObserver<SimpleMessage> responseObserver) {
         cmdLogger.info("cmd={}|{}|client2eventMesh|from={}|to={}", 
"RequestReply",
             EventMeshConstants.PROTOCOL_GRPC, request.getHeader().getIp(),
@@ -91,6 +93,7 @@ public class ProducerService extends 
PublisherServiceGrpc.PublisherServiceImplBa
         });
     }
 
+    @Override
     public void batchPublish(BatchMessage request, StreamObserver<Response> 
responseObserver) {
         cmdLogger.info("cmd={}|{}|client2eventMesh|from={}|to={}", 
"BatchPublish",
             EventMeshConstants.PROTOCOL_GRPC, request.getHeader().getIp(),


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@eventmesh.apache.org
For additional commands, e-mail: commits-h...@eventmesh.apache.org