Make UTs to pass

apache · Feb 17, 2025 · 32fa5a7 · 32fa5a7
1 parent 0c67199
commit 32fa5a7
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/.../src/test/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessorTest.java b/.../src/test/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessorTest.java
@@ -111,7 +111,7 @@ public void init() throws IllegalAccessException, NoSuchFieldException {
     }
 
     @Test
-    public void testProcessRequest_Success() throws RemotingCommandException, InterruptedException, RemotingTimeoutException, RemotingSendRequestException, ConsumeQueueException {
+    public void testProcessRequest_Success() throws RemotingCommandException, ConsumeQueueException {
         when(messageStore.getMaxOffsetInQueue(anyString(), anyInt())).thenReturn(2L);
         when(escapeBridge.asyncPutMessageToSpecificQueue(any(MessageExtBrokerInner.class))).thenReturn(CompletableFuture.completedFuture(new PutMessageResult(PutMessageStatus.PUT_OK, new AppendMessageResult(AppendMessageStatus.PUT_OK))));
         int queueId = 0;
@@ -139,9 +139,8 @@ public void testProcessRequest_Success() throws RemotingCommandException, Interr
     }
 
     @Test
-    public void testProcessRequest_NoMessage() throws RemotingCommandException, InterruptedException, RemotingTimeoutException, RemotingSendRequestException, ConsumeQueueException {
+    public void testProcessRequest_NoMessage() throws RemotingCommandException, ConsumeQueueException {
         when(messageStore.getMaxOffsetInQueue(anyString(), anyInt())).thenReturn(2L);
-        when(escapeBridge.asyncPutMessageToSpecificQueue(any(MessageExtBrokerInner.class))).thenReturn(CompletableFuture.completedFuture(new PutMessageResult(PutMessageStatus.PUT_OK, new AppendMessageResult(AppendMessageStatus.PUT_OK))));
         int queueId = 0;
         long queueOffset = 2;
         long popTime = System.currentTimeMillis() - 1_000;