web: fix tests for consumer-aware getExplorePageData + peek signatures

The earlier consumer-aware peek work changed two SPI surfaces that the
web tests still called with the old shape, so CI failed at compile
time on rqueue-web:compileTestJava.

RqueueQDetailService.getExplorePageData gained a String consumerName
between DataType and pageNumber. Updated five call sites in
RqueueQDetailServiceTest and three in RqueueQDetailServiceBrokerRoutingTest
to pass null for consumerName.

MessageBroker.peek gained a consumer-aware 4-arg overload, and the
production explorer path now calls that overload. Two stubbings and
one verify in RqueueQDetailServiceBrokerRoutingTest were still
matching peek(QueueDetail, long, long) — strict Mockito reported a
PotentialStubbingProblem. Updated to nullable(String.class) for the
consumer arg so the stub matches both the explicit-null and any
future non-null call sites.

Assisted-By: Claude Code

Author: sonus21

rqueue-web/src/test/java/com/github/sonus21/rqueue/web/service/RqueueQDetailServiceBrokerRoutingTest.java

@@ -22,6 +22,7 @@
 import static org.junit.jupiter.api.Assertions.assertTrue;
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.ArgumentMatchers.anyLong;
+import static org.mockito.ArgumentMatchers.nullable;
 import static org.mockito.Mockito.atLeastOnce;
 import static org.mockito.Mockito.never;
 import static org.mockito.Mockito.verify;
@@ -175,7 +176,7 @@ void scheduledAndRunningTabsHiddenForNatsBroker() {
 
     when(rqueueSystemManagerService.getQueueConfig(queueConfig.getName())).thenReturn(queueConfig);
     DataViewResponse explore = service.getExplorePageData(
-        queueConfig.getName(), queueConfig.getScheduledQueueName(), DataType.ZSET, 0, 10);
+        queueConfig.getName(), queueConfig.getScheduledQueueName(), DataType.ZSET, null, 0, 10);
     assertTrue(explore.isHideScheduledPanel());
     assertTrue(explore.isHideCronJobs());
     assertTrue(explore.getRows() == null || explore.getRows().isEmpty());
@@ -185,27 +186,27 @@ void scheduledAndRunningTabsHiddenForNatsBroker() {
   void peekRoutesThroughBrokerForReadyList() {
     service.setMessageBroker(messageBroker);
     when(messageBroker.capabilities()).thenReturn(Capabilities.REDIS_DEFAULTS);
-    when(messageBroker.peek(any(QueueDetail.class), anyLong(), anyLong()))
+    when(messageBroker.peek(any(QueueDetail.class), nullable(String.class), anyLong(), anyLong()))
         .thenReturn(Collections.emptyList());
     when(rqueueSystemManagerService.getQueueConfig(queueConfig.getName())).thenReturn(queueConfig);
 
     DataViewResponse response = service.getExplorePageData(
-        queueConfig.getName(), queueConfig.getQueueName(), DataType.LIST, 0, 10);
+        queueConfig.getName(), queueConfig.getQueueName(), DataType.LIST, null, 0, 10);
 
-    verify(messageBroker, atLeastOnce()).peek(any(QueueDetail.class), anyLong(), anyLong());
+    verify(messageBroker, atLeastOnce()).peek(any(QueueDetail.class), nullable(String.class), anyLong(), anyLong());
     assertTrue(response.getRows() == null || response.getRows().isEmpty());
   }
 
   @Test
   void hideFlagsDefaultFalseWithRedisBroker() {
     service.setMessageBroker(messageBroker);
     when(messageBroker.capabilities()).thenReturn(Capabilities.REDIS_DEFAULTS);
-    when(messageBroker.peek(any(QueueDetail.class), anyLong(), anyLong()))
+    when(messageBroker.peek(any(QueueDetail.class), nullable(String.class), anyLong(), anyLong()))
         .thenReturn(Collections.emptyList());
     when(rqueueSystemManagerService.getQueueConfig(queueConfig.getName())).thenReturn(queueConfig);
 
     DataViewResponse response = service.getExplorePageData(
-        queueConfig.getName(), queueConfig.getQueueName(), DataType.LIST, 0, 10);
+        queueConfig.getName(), queueConfig.getQueueName(), DataType.LIST, null, 0, 10);
 
     assertFalse(response.isHideScheduledPanel());
     assertFalse(response.isHideCronJobs());

rqueue-web/src/test/java/com/github/sonus21/rqueue/web/service/RqueueQDetailServiceTest.java

@@ -239,7 +239,7 @@ void getExplorePageDataQueue() {
     doReturn(queueConfig).when(rqueueSystemManagerService).getQueueConfig("test");
     doReturn(rqueueMessages).when(rqueueMessageTemplate).readFromList("test", 0, 9);
     DataViewResponse response =
-        rqueueQDetailService.getExplorePageData("test", "test", DataType.LIST, 0, 10);
+        rqueueQDetailService.getExplorePageData("test", "test", DataType.LIST, null, 0, 10);
     assertEquals(expectedResponse, response);
   }
 
@@ -273,7 +273,7 @@ void getExplorePageDataDeadLetterQueue() {
     doReturn(queueConfig).when(rqueueSystemManagerService).getQueueConfig("test");
     doReturn(rqueueMessages).when(rqueueMessageTemplate).readFromList("test-dlq", 0, 9);
     DataViewResponse response =
-        rqueueQDetailService.getExplorePageData("test", "test-dlq", DataType.LIST, 0, 10);
+        rqueueQDetailService.getExplorePageData("test", "test-dlq", DataType.LIST, null, 0, 10);
     for (TableRow row : response.getRows()) {
       assertNotEquals("", row.getColumns().get(3).getValue());
       row.getColumns().remove(3);
@@ -326,7 +326,7 @@ void getExplorePageDataTypeQueueDeleteFewItems() {
     doReturn(messageMetadata).when(rqueueMessageMetadataService).findAll(anyCollection());
     doReturn(queueConfig).when(rqueueSystemManagerService).getQueueConfig("test");
     DataViewResponse response =
-        rqueueQDetailService.getExplorePageData("test", "test", DataType.LIST, 0, 10);
+        rqueueQDetailService.getExplorePageData("test", "test", DataType.LIST, null, 0, 10);
     assertEquals(expectedResponse, response);
   }
 
@@ -364,7 +364,7 @@ void getExplorePageDataTypeScheduledQueue() {
     doReturn(queueConfig).when(rqueueSystemManagerService).getQueueConfig("test");
     doReturn(rqueueMessages).when(rqueueMessageTemplate).readFromZset("__rq::d-queue::test", 0, 9);
     DataViewResponse response = rqueueQDetailService.getExplorePageData(
-        "test", "__rq::d-queue::test", DataType.ZSET, 0, 10);
+        "test", "__rq::d-queue::test", DataType.ZSET, null, 0, 10);
     // clear time left
     for (TableRow tableRow : response.getRows()) {
       tableRow.getColumns().remove(3);
@@ -409,7 +409,7 @@ void getExplorePageDataTypeProcessingQueue() {
         .readFromZsetWithScore("__rq::p-queue::test", 0, 9);
 
     DataViewResponse response = rqueueQDetailService.getExplorePageData(
-        "test", "__rq::p-queue::test", DataType.ZSET, 0, 10);
+        "test", "__rq::p-queue::test", DataType.ZSET, null, 0, 10);
     // clear time left
     for (TableRow tableRow : response.getRows()) {
       tableRow.getColumns().remove(3);