This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-apis.git
The following commit(s) were added to refs/heads/main by this push:
new 70eb1ef Add comments for pull-related RPC (#82)
70eb1ef is described below
commit 70eb1effd4b415678fc7214cedd3a289b0f926b9
Author: Aaron Ai <[email protected]>
AuthorDate: Thu Jun 8 13:44:59 2023 +0800
Add comments for pull-related RPC (#82)
---
apache/rocketmq/v2/service.proto | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/apache/rocketmq/v2/service.proto b/apache/rocketmq/v2/service.proto
index ae534f9..513a103 100644
--- a/apache/rocketmq/v2/service.proto
+++ b/apache/rocketmq/v2/service.proto
@@ -378,12 +378,19 @@ service MessagingService {
rpc ForwardMessageToDeadLetterQueue(ForwardMessageToDeadLetterQueueRequest)
returns (ForwardMessageToDeadLetterQueueResponse) {}
+ // PullMessage and ReceiveMessage RPCs serve a similar purpose,
+ // which is to attempt to get messages from the server, but with different
semantics.
rpc PullMessage(PullMessageRequest) returns (stream PullMessageResponse) {}
+ // Update the consumption progress of the designated queue of the
+ // consumer group to the remote.
rpc UpdateOffset(UpdateOffsetRequest) returns (UpdateOffsetResponse) {}
+ // Query the consumption progress of the designated queue of the
+ // consumer group to the remote.
rpc GetOffset(GetOffsetRequest) returns (GetOffsetResponse) {}
+ // Query the offset of the designated queue by the query offset policy.
rpc QueryOffset(QueryOffsetRequest) returns (QueryOffsetResponse) {}
// Commits or rollback one transactional message.
