From 70eb1effd4b415678fc7214cedd3a289b0f926b9 Mon Sep 17 00:00:00 2001 From: Aaron Ai Date: Thu, 8 Jun 2023 13:44:59 +0800 Subject: [PATCH] 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.