Skip to content
Snippets Groups Projects
Commit 9b155afb authored by Vibhuti Sharma [Microsoft]'s avatar Vibhuti Sharma [Microsoft]
Browse files

overloading correct method

parent 55b93062
No related branches found
No related tags found
1 merge request!205Fixing retry functionality
Pipeline #67515 failed
...@@ -79,6 +79,12 @@ public class IndexerQueueTaskBuilderAzure extends IndexerQueueTaskBuilder { ...@@ -79,6 +79,12 @@ public class IndexerQueueTaskBuilderAzure extends IndexerQueueTaskBuilder {
createTask(payload, headers); createTask(payload, headers);
} }
@Override
public void createReIndexTask(String payload, DpsHeaders headers) {
headers.addCorrelationIdIfMissing();
publishAllRecordsToServiceBus(payload, headers);
}
@Override @Override
public void createReIndexTask(String payload, Long countdownMillis, DpsHeaders headers) { public void createReIndexTask(String payload, Long countdownMillis, DpsHeaders headers) {
headers.addCorrelationIdIfMissing(); headers.addCorrelationIdIfMissing();
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment