diff --git a/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcClientSettingsManagerTest.java b/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcClientSettingsManagerTest.java index 28a422df0fb..96e1e6dd535 100644 --- a/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcClientSettingsManagerTest.java +++ b/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcClientSettingsManagerTest.java @@ -70,7 +70,7 @@ public void testGetSubscriptionData() { subscriptionGroupConfig.getGroupRetryPolicy().setCustomizedRetryPolicy(new CustomizedRetryPolicy(new long[] {1000})); settings = this.grpcClientSettingsManager.getClientSettings(context); assertEquals(RetryPolicy.newBuilder() - .setMaxAttempts(3) + .setMaxAttempts(4) .setCustomizedBackoff(CustomizedBackoff.newBuilder() .addNext(Durations.fromSeconds(1)) .build()) @@ -81,7 +81,7 @@ public void testGetSubscriptionData() { subscriptionGroupConfig.getGroupRetryPolicy().setExponentialRetryPolicy(new ExponentialRetryPolicy(1000, 2000, 3)); settings = this.grpcClientSettingsManager.getClientSettings(context); assertEquals(RetryPolicy.newBuilder() - .setMaxAttempts(10) + .setMaxAttempts(11) .setExponentialBackoff(ExponentialBackoff.newBuilder() .setMax(Durations.fromSeconds(2)) .setInitial(Durations.fromSeconds(1)) diff --git a/test/src/test/java/org/apache/rocketmq/test/grpc/v2/GrpcBaseIT.java b/test/src/test/java/org/apache/rocketmq/test/grpc/v2/GrpcBaseIT.java index 434aceae961..14f536be5ca 100644 --- a/test/src/test/java/org/apache/rocketmq/test/grpc/v2/GrpcBaseIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/grpc/v2/GrpcBaseIT.java @@ -391,7 +391,7 @@ public void testSimpleConsumerToDLQ() throws Exception { int maxDeliveryAttempts = 2; SubscriptionGroupConfig groupConfig = brokerController1.getSubscriptionGroupManager().findSubscriptionGroupConfig(group); - groupConfig.setRetryMaxTimes(maxDeliveryAttempts); + groupConfig.setRetryMaxTimes(maxDeliveryAttempts - 1); brokerController1.getSubscriptionGroupManager().updateSubscriptionGroupConfig(groupConfig); brokerController2.getSubscriptionGroupManager().updateSubscriptionGroupConfig(groupConfig); brokerController3.getSubscriptionGroupManager().updateSubscriptionGroupConfig(groupConfig);