fix test code

apache · Sep 21, 2022 · 9ab3fa1 · 9ab3fa1
1 parent 728736f
commit 9ab3fa1
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git a/...r-broker/src/main/java/org/apache/pulsar/broker/delayed/BucketDelayedDeliveryTracker.java b/...r-broker/src/main/java/org/apache/pulsar/broker/delayed/BucketDelayedDeliveryTracker.java
@@ -61,7 +61,7 @@
 @ThreadSafe
 public class BucketDelayedDeliveryTracker extends InMemoryDelayedDeliveryTracker {
 
-    public static final String DELAYED_BUCKET_KEY_PREFIX = "#pulsar_internal.delayed.bucket";
+    public static final String DELAYED_BUCKET_KEY_PREFIX = "#pulsar.internal.delayed.bucket";
 
     public static final String DELIMITER = "_";
 

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);