[rocketmq-apis] branch v2 updated: Add clang-format to format proto files

[li...@apache.org]

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

lizhanhui pushed a commit to branch v2
in repository https://gitbox.apache.org/repos/asf/rocketmq-apis.git


The following commit(s) were added to refs/heads/v2 by this push:
     new 98227cd  Add clang-format to format proto files
98227cd is described below

commit 98227cdc45ee9945b7ca1cfff510ba346b4c3da9
Author: Li Zhanhui <li...@gmail.com>
AuthorDate: Thu Apr 21 11:13:04 2022 +0000

    Add clang-format to format proto files
---
 .clang-format                    |  5 +++++
 apache/rocketmq/v2/service.proto | 16 ++++++++--------
 2 files changed, 13 insertions(+), 8 deletions(-)

diff --git a/.clang-format b/.clang-format
new file mode 100644
index 0000000..1dd4061
--- /dev/null
+++ b/.clang-format
@@ -0,0 +1,5 @@
+Language: Proto
+ColumnLimit: 120
+SpacesInContainerLiterals: false
+AllowShortFunctionsOnASingleLine: None
+ReflowComments: false
\ No newline at end of file
diff --git a/apache/rocketmq/v2/service.proto b/apache/rocketmq/v2/service.proto
index d216f51..3093a60 100644
--- a/apache/rocketmq/v2/service.proto
+++ b/apache/rocketmq/v2/service.proto
@@ -352,8 +352,8 @@ service MessagingService {
   //
   // If the corresponding topic doesn't exist, returns `NOT_FOUND`.
   // If the specific endpoints is empty, returns `INVALID_ARGUMENT`.
-  rpc QueryAssignment(QueryAssignmentRequest)
-      returns (QueryAssignmentResponse) {}
+  rpc QueryAssignment(QueryAssignmentRequest) returns (QueryAssignmentResponse) {
+  }
 
   // Receives messages from the server in batch manner, returns a set of
   // messages if success. The received messages should be acked or nacked after
@@ -365,8 +365,8 @@ service MessagingService {
   // or consumer group doesn't exist, returns `NOT_FOUND`. If there is no new
   // message in the specific topic, returns `OK` with an empty message set.
   // Please note that client may suffer from false empty responses.
-  rpc ReceiveMessage(ReceiveMessageRequest)
-      returns (stream ReceiveMessageResponse) {}
+  rpc ReceiveMessage(ReceiveMessageRequest) returns (stream ReceiveMessageResponse) {
+  }
 
   // Acknowledges the message associated with the `receipt_handle` or `offset`
   // in the `AckMessageRequest`, it means the message has been successfully
@@ -402,8 +402,8 @@ service MessagingService {
   rpc Telemetry(stream TelemetryCommand) returns (stream TelemetryCommand) {}
 
   // Notify the server that the client is terminated.
-  rpc NotifyClientTermination(NotifyClientTerminationRequest)
-      returns (NotifyClientTerminationResponse) {}
+  rpc NotifyClientTermination(NotifyClientTerminationRequest) returns (NotifyClientTerminationResponse) {
+  }
 
   // Once a message is retrieved from consume queue on behalf of the group, it
   // will be kept invisible to other clients of the same group for a period of
@@ -411,6 +411,6 @@ service MessagingService {
   // duration. If the client, which is in charge of the invisible message, is
   // not capable of processing the message timely, it may use
   // ChangeInvisibleDuration to lengthen invisible duration.
-  rpc ChangeInvisibleDuration(ChangeInvisibleDurationRequest)
-      returns (ChangeInvisibleDurationResponse) {}
+  rpc ChangeInvisibleDuration(ChangeInvisibleDurationRequest) returns (ChangeInvisibleDurationResponse) {
+  }
 }
\ No newline at end of file