fix: fix the setMaxRetryAttempt

Signed-off-by: wangxye <[email protected]>
AutoMQ · Oct 31, 2023 · 550a230 · 550a230
1 parent 19a8c44
commit 550a230
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/java/e2e/src/main/java/org/apache/rocketmq/frame/BaseOperate.java b/java/e2e/src/main/java/org/apache/rocketmq/frame/BaseOperate.java
@@ -148,7 +148,7 @@ protected static String getGroupId(String methodName) {
         // prepare consumer group
         CreateGroupRequest request = CreateGroupRequest.newBuilder()
             .setName(groupId)
-            .setMaxRetryAttempt(16)
+            .setMaxDeliveryAttempt(16)
             .setGroupType(GroupType.GROUP_TYPE_STANDARD)
             .build();
         CreateGroupReply reply = createConsumerGroup(request).join();
@@ -161,7 +161,7 @@ protected static String getOrderlyGroupId(String methodName) {
         String groupId = String.format("GID_%s_%s", methodName, RandomUtils.getStringWithCharacter(6));
         CreateGroupRequest request = CreateGroupRequest.newBuilder()
             .setName(groupId)
-            .setMaxRetryAttempt(16)
+            .setMaxDeliveryAttempt(16)
             .setGroupType(GroupType.GROUP_TYPE_FIFO)
             .build();
         CreateGroupReply reply = createConsumerGroup(request).join();