fix unit test

Change-Id: If3387de9605696bb62008658386790a52b55654d

Author: f1amingo

proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/consumer/AckMessageActivityTest.java

@@ -69,17 +69,17 @@ public void testAckMessage() throws Throwable {
         String msg2 = "msg2";
         String msg3 = "msg3";
 
-        when(this.messagingProcessor.ackMessage(any(), any(), eq(msg1), anyString(), anyString()))
+        when(this.messagingProcessor.ackMessage(any(), any(), eq(msg1), anyString(), anyString(), any()))
             .thenThrow(new ProxyException(ProxyExceptionCode.INVALID_RECEIPT_HANDLE, "receipt handle is expired"));
 
         AckResult msg2AckResult = new AckResult();
         msg2AckResult.setStatus(AckStatus.OK);
-        when(this.messagingProcessor.ackMessage(any(), any(), eq(msg2), anyString(), anyString()))
+        when(this.messagingProcessor.ackMessage(any(), any(), eq(msg2), anyString(), anyString(), any()))
             .thenReturn(CompletableFuture.completedFuture(msg2AckResult));
 
         AckResult msg3AckResult = new AckResult();
         msg3AckResult.setStatus(AckStatus.NO_EXIST);
-        when(this.messagingProcessor.ackMessage(any(), any(), eq(msg3), anyString(), anyString()))
+        when(this.messagingProcessor.ackMessage(any(), any(), eq(msg3), anyString(), anyString(), any()))
             .thenReturn(CompletableFuture.completedFuture(msg3AckResult));
 
         {

proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/ForwardMessageToDLQActivityTest.java

@@ -50,7 +50,7 @@ public void before() throws Throwable {
     @Test
     public void testForwardMessageToDeadLetterQueue() throws Throwable {
         ArgumentCaptor<ReceiptHandle> receiptHandleCaptor = ArgumentCaptor.forClass(ReceiptHandle.class);
-        when(this.messagingProcessor.forwardMessageToDeadLetterQueue(any(), receiptHandleCaptor.capture(), anyString(), anyString(), anyString()))
+        when(this.messagingProcessor.forwardMessageToDeadLetterQueue(any(), receiptHandleCaptor.capture(), anyString(), anyString(), anyString(), any()))
             .thenReturn(CompletableFuture.completedFuture(RemotingCommand.createResponseCommand(ResponseCode.SUCCESS, "")));
 
         String handleStr = buildReceiptHandle("topic", System.currentTimeMillis(), 3000);
@@ -71,7 +71,7 @@ public void testForwardMessageToDeadLetterQueue() throws Throwable {
     @Test
     public void testForwardMessageToDeadLetterQueueWhenHasMappingHandle() throws Throwable {
         ArgumentCaptor<ReceiptHandle> receiptHandleCaptor = ArgumentCaptor.forClass(ReceiptHandle.class);
-        when(this.messagingProcessor.forwardMessageToDeadLetterQueue(any(), receiptHandleCaptor.capture(), anyString(), anyString(), anyString()))
+        when(this.messagingProcessor.forwardMessageToDeadLetterQueue(any(), receiptHandleCaptor.capture(), anyString(), anyString(), anyString(), any()))
             .thenReturn(CompletableFuture.completedFuture(RemotingCommand.createResponseCommand(ResponseCode.SUCCESS, "")));
 
         String savedHandleStr = buildReceiptHandle("topic", System.currentTimeMillis(),3000);

proxy/src/test/java/org/apache/rocketmq/proxy/processor/ClientProcessorTest.java

@@ -20,22 +20,25 @@
 import java.util.HashSet;
 import java.util.Set;
 import org.apache.rocketmq.proxy.common.ProxyContext;
+import org.apache.rocketmq.proxy.config.ConfigurationManager;
 import org.apache.rocketmq.proxy.grpc.v2.common.GrpcProxyException;
 import org.apache.rocketmq.proxy.service.ServiceManager;
 import org.apache.rocketmq.remoting.protocol.heartbeat.MessageModel;
 import org.apache.rocketmq.remoting.protocol.heartbeat.SubscriptionData;
 import org.apache.rocketmq.remoting.protocol.subscription.SubscriptionGroupConfig;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
 import org.mockito.Mock;
-import org.mockito.MockitoAnnotations;
+import org.mockito.junit.jupiter.MockitoExtension;
 
 import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertThrows;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 import static org.mockito.Mockito.when;
 
+@ExtendWith(MockitoExtension.class)
 class ClientProcessorTest {
 
     @Mock
@@ -53,8 +56,8 @@ class ClientProcessorTest {
     private ClientProcessor clientProcessor;
 
     @BeforeEach
-    void setUp() {
-        MockitoAnnotations.openMocks(this);
+    void setUp() throws Exception {
+        ConfigurationManager.intConfig();
         clientProcessor = new ClientProcessor(messagingProcessor, serviceManager);
     }
 
@@ -180,7 +183,7 @@ void testValidateLiteSubscriptionQuota_withinQuota_noException() {
     void testValidateLiteSubscriptionQuota_exceedsQuota_throwsException() {
         String group = "group";
         int quota = 10;
-        int actual = 15;
+        int actual = 15 + 300 /*quota buffer*/;
 
         when(groupConfig.getLiteSubClientQuota()).thenReturn(quota);
         when(messagingProcessor.getSubscriptionGroupConfig(ctx, group)).thenReturn(groupConfig);