diff --git a/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/util/IndexerQueueTaskBuilderAzure.java b/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/util/IndexerQueueTaskBuilderAzure.java
index cc40080695ed99164aa7d678f6339f6a90a8e29a..914fba0a1ed1466be681f6be47e0f600a86e251f 100644
--- a/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/util/IndexerQueueTaskBuilderAzure.java
+++ b/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/util/IndexerQueueTaskBuilderAzure.java
@@ -79,6 +79,12 @@ public class IndexerQueueTaskBuilderAzure extends IndexerQueueTaskBuilder {
         createTask(payload, headers);
     }
 
+    @Override
+    public void createReIndexTask(String payload, DpsHeaders headers) {
+        headers.addCorrelationIdIfMissing();
+        publishAllRecordsToServiceBus(payload, headers);
+    }
+
     @Override
     public void createReIndexTask(String payload, Long countdownMillis, DpsHeaders headers) {
         headers.addCorrelationIdIfMissing();