Fixed ReducedPropagationManagerTest

swisspost · Jan 17, 2024 · a01e882 · a01e882
1 parent c7fef85
commit a01e882
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...st/java/org/swisspush/gateleen/hook/reducedpropagation/ReducedPropagationManagerTest.java b/...st/java/org/swisspush/gateleen/hook/reducedpropagation/ReducedPropagationManagerTest.java
@@ -114,7 +114,7 @@ public void testProcessIncomingRequestWithAddQueueStorageError(TestContext conte
             ArgumentCaptor<String> queuesCaptor = ArgumentCaptor.forClass(String.class);
 
             verify(requestQueue, timeout(1000).times(1)).lockedEnqueue(requestCaptor.capture(),
-                    queuesCaptor.capture(), eq(LOCK_REQUESTER), any(Handler.class));
+                    queuesCaptor.capture(), eq(LOCK_REQUESTER), isNull());
 
             // verify that request has been locked-enqueued in original queue
             HttpRequest originalEnqueue = requestCaptor.getValue();
@@ -159,7 +159,7 @@ public void testProcessIncomingRequestStartingNewTimerAndSuccessfulStoreQueueReq
             ArgumentCaptor<String> queuesCaptor = ArgumentCaptor.forClass(String.class);
 
             verify(requestQueue, timeout(1000).times(1)).lockedEnqueue(requestCaptor.capture(),
-                    queuesCaptor.capture(), eq(LOCK_REQUESTER), any(Handler.class));
+                    queuesCaptor.capture(), eq(LOCK_REQUESTER), isNull());
 
             List<HttpRequest> requests = requestCaptor.getAllValues();
             List<String> queues = queuesCaptor.getAllValues();
@@ -212,7 +212,7 @@ public void testProcessIncomingRequestStartingNewTimerAndFailingStoreQueueReques
             ArgumentCaptor<String> queuesCaptor = ArgumentCaptor.forClass(String.class);
 
             verify(requestQueue, timeout(1000).times(1)).lockedEnqueue(requestCaptor.capture(),
-                    queuesCaptor.capture(), eq(LOCK_REQUESTER), any(Handler.class));
+                    queuesCaptor.capture(), eq(LOCK_REQUESTER), isNull());
 
             List<HttpRequest> requests = requestCaptor.getAllValues();
             List<String> queues = queuesCaptor.getAllValues();
@@ -262,7 +262,7 @@ public void testProcessIncomingRequestStartingExistingTimer(TestContext context)
             ArgumentCaptor<String> queuesCaptor = ArgumentCaptor.forClass(String.class);
 
             verify(requestQueue, timeout(1000).times(1)).lockedEnqueue(requestCaptor.capture(),
-                    queuesCaptor.capture(), eq(LOCK_REQUESTER), any(Handler.class));
+                    queuesCaptor.capture(), eq(LOCK_REQUESTER), isNull());
 
             // verify that request has been locked-enqueued in original queue
             HttpRequest originalEnqueue = requestCaptor.getValue();