@@ -338,11 +338,11 @@ public void analyzeBacklogWithIndividualAck() throws Exception {
338338 consumer .acknowledge (message );
339339 }
340340
341- verifyClientSideLoopBacklog (topic , subName , backlogScanMaxEntries , 0 , null ,
342- null );
341+ verifyClientSideLoopBacklog (topic , subName , backlogScanMaxEntries , 0 , null , null );
343342 }
344343
345- private List <MessageId > clientSideLoopAnalyzeBacklogSetup (String topic , String subName , int numMessages ) throws Exception {
344+ private List <MessageId > clientSideLoopAnalyzeBacklogSetup (String topic , String subName , int numMessages )
345+ throws Exception {
346346 admin .topics ().createSubscription (topic , subName , MessageId .latest );
347347
348348 assertEquals (admin .topics ().getSubscriptions (topic ), List .of ("sub-1" ));
@@ -359,8 +359,8 @@ private List<MessageId> clientSideLoopAnalyzeBacklogSetup(String topic, String s
359359 }
360360
361361 private void verifyClientSideLoopBacklog (String topic , String subName , int backlogMaxScanEntries ,
362- int expectedEntries , MessageId firstMessageId ,
363- MessageId lastMessageId ) throws Exception {
362+ int expectedEntries , MessageId firstMessageId , MessageId lastMessageId )
363+ throws Exception {
364364 AnalyzeSubscriptionBacklogResult backlogResult =
365365 admin .topics ().analyzeSubscriptionBacklog (topic , subName , Optional .empty (), backlogMaxScanEntries );
366366
0 commit comments