You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2022/03/21 07:33:18 UTC
[rocketmq-apis] branch v2 updated: Remove Nack API
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 1de1b3e Remove Nack API
1de1b3e is described below
commit 1de1b3e90ffd7e7f74dd3a4a9a52c665cb44c7fa
Author: Li Zhanhui <li...@gmail.com>
AuthorDate: Mon Mar 21 07:33:09 2022 +0000
Remove Nack API
---
apache/rocketmq/v2/service.proto | 22 ----------------------
1 file changed, 22 deletions(-)
diff --git a/apache/rocketmq/v2/service.proto b/apache/rocketmq/v2/service.proto
index 4163344..2864f54 100644
--- a/apache/rocketmq/v2/service.proto
+++ b/apache/rocketmq/v2/service.proto
@@ -128,20 +128,6 @@ message AckMessageResponse {
ResponseCommon common = 1;
}
-message NackMessageRequest {
- Resource group = 1;
- Resource topic = 2;
- string client_id = 3;
- string receipt_handle = 4;
- string message_id = 5;
- int32 delivery_attempt = 6;
- int32 max_delivery_attempts = 7;
-}
-
-message NackMessageResponse {
- ResponseCommon common = 1;
-}
-
message ForwardMessageToDeadLetterQueueRequest {
Resource group = 1;
Resource topic = 2;
@@ -375,14 +361,6 @@ service MessagingService {
// `INVALID_ARGUMENT`.
rpc AckMessage(AckMessageRequest) returns (AckMessageResponse) {}
- // Signals that the message has not been successfully processed. The message
- // server should resend the message follow the retry policy defined at
- // server-side.
- //
- // If the corresponding topic or consumer group doesn't exist, returns
- // `NOT_FOUND`.
- rpc NackMessage(NackMessageRequest) returns (NackMessageResponse) {}
-
// Forwards one message to dead letter queue if the DeadLetterPolicy is
// triggered by this message at client-side, return `OK` if success.
rpc ForwardMessageToDeadLetterQueue(ForwardMessageToDeadLetterQueueRequest)