fix test code

apache · Sep 20, 2022 · 582b076 · 582b076
1 parent 728736f
commit 582b076
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/...ar-broker/src/test/java/org/apache/pulsar/broker/delayed/InMemoryDeliveryTrackerTest.java b/...ar-broker/src/test/java/org/apache/pulsar/broker/delayed/InMemoryDeliveryTrackerTest.java
@@ -305,7 +305,6 @@ public void testAddMessageWithDeliverAtTimeAfterFullTickTimeWithStrict(DelayedDe
         // Wait longer than the tick time plus the HashedWheelTimer's tick time to ensure that enough time has
         // passed where it would have been triggered if the tick time was doing the triggering.
         Thread.sleep(1000);
-        verify(dispatcher).getCursor();
 
         // Not wait for the message delivery to get triggered.
         Awaitility.await().atMost(10, TimeUnit.SECONDS)

diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/delayed/MockManagedCursor.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/delayed/MockManagedCursor.java
@@ -38,7 +38,7 @@ public class MockManagedCursor implements ManagedCursor {
 
     private final String name;
 
-    private Map<String, String> cursorProperties;
+    private final Map<String, String> cursorProperties;
 
     public MockManagedCursor(String name) {
         this.name = name;
@@ -76,6 +76,11 @@ public CompletableFuture<Void> putCursorProperty(String key, String value) {
         return CompletableFuture.completedFuture(null);
     }
 
+    @Override
+    public CompletableFuture<Void> setCursorProperties(Map<String, String> cursorProperties) {
+        return CompletableFuture.completedFuture(null);
+    }
+
     public CompletableFuture<Void> removeCursorProperty(String key) {
         cursorProperties.remove(key);
         return CompletableFuture.completedFuture(null);