Skip to content

Commit

Permalink
style(store): fix checkstyle
Browse files Browse the repository at this point in the history
1. fix checkstyle

Signed-off-by: TheR1sing3un <[email protected]>
  • Loading branch information
TheR1sing3un committed Oct 20, 2023
1 parent 83edc63 commit 15c88fc
Showing 1 changed file with 6 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@
import com.automq.rocketmq.common.model.FlatMessageExt;
import com.automq.rocketmq.common.model.generated.FlatMessage;
import com.automq.rocketmq.metadata.api.StoreMetadataService;
import com.automq.rocketmq.store.MessageStoreImpl;
import com.automq.rocketmq.store.api.DLQSender;
import com.automq.rocketmq.store.api.LogicQueue;
import com.automq.rocketmq.store.api.LogicQueueManager;
Expand Down Expand Up @@ -171,13 +170,12 @@ void tryRevive_normal() throws StoreException {
@Test
void tryRevive_fifo() throws StoreException {
Mockito.doAnswer(ink -> {
long consumerGroupId = ink.getArgument(0);
assertEquals(CONSUMER_GROUP_ID, consumerGroupId);
FlatMessageExt flatMessageExt = ink.getArgument(1);
assertNotNull(flatMessageExt);
return CompletableFuture.completedFuture(null);
}).when(dlqSender)
.send(Mockito.anyLong(), Mockito.any(FlatMessageExt.class));
long consumerGroupId = ink.getArgument(0);
assertEquals(CONSUMER_GROUP_ID, consumerGroupId);
FlatMessageExt flatMessageExt = ink.getArgument(1);
assertNotNull(flatMessageExt);
return CompletableFuture.completedFuture(null);
}).when(dlqSender).send(Mockito.anyLong(), Mockito.any(FlatMessageExt.class));
// mock max delivery attempts
Mockito.doReturn(CompletableFuture.completedFuture(2))
.when(metadataService).maxDeliveryAttemptsOf(Mockito.anyLong());
Expand Down

0 comments on commit 15c88fc

Please sign in to comment.