do I need this?

clebertsuconic · Jan 24, 2025 · 31cce30 · 31cce30
1 parent 1833251
commit 31cce30
Showing 1 changed file with 20 additions and 0 deletions.
diff --git a/...main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageCursorProviderImpl.java b/...main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageCursorProviderImpl.java
@@ -209,6 +209,25 @@ public Future<Boolean> scheduleCleanup() {
 
       return future;
    }
+   public Future<Boolean> forceScheduleCleanup() {
+      final SimpleFutureImpl<Boolean> future = new SimpleFutureImpl<>();
+
+      pagingStore.execute(() -> {
+         storageManager.setContext(storageManager.newSingleThreadContext());
+         try {
+            System.out.println("Forcing cleanup");
+            if (cleanupEnabled) {
+               cleanup();
+            }
+         } finally {
+            storageManager.clearContext();
+            future.set(true);
+         }
+      });
+
+      return future;
+   }
+
 
    /**
     * Delete everything associated with any queue on this address.
@@ -272,6 +291,7 @@ protected void cleanup() {
       }
 
       if (pagingStore.hasPendingIO()) {
+         forceScheduleCleanup();
          return;
       }