Add retry on delete operation in case of concurrency exception

slim-gears · Oct 30, 2019 · 2fbeed2 · 2fbeed2
1 parent 7622bbd
commit 2fbeed2
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/rxrepo-core/src/main/java/com/slimgears/rxrepo/query/DefaultEntitySet.java b/rxrepo-core/src/main/java/com/slimgears/rxrepo/query/DefaultEntitySet.java
@@ -66,7 +66,12 @@ public Single<Integer> execute() {
                 return queryProvider.delete(builder
                         .metaClass(metaClass)
                         .predicate(predicate.get())
-                        .build());
+                        .build())
+                        .compose(Singles.backOffDelayRetry(
+                                DefaultEntitySet::isConcurrencyException,
+                                Duration.ofMillis(config.retryInitialDurationMillis()),
+                                config.retryCount()));
+
             }
 
             @Override