diff --git a/src/main/java/org/springframework/data/couchbase/core/ReactiveRemoveByIdOperationSupport.java b/src/main/java/org/springframework/data/couchbase/core/ReactiveRemoveByIdOperationSupport.java index 2e7427f2..7e45b2cf 100644 --- a/src/main/java/org/springframework/data/couchbase/core/ReactiveRemoveByIdOperationSupport.java +++ b/src/main/java/org/springframework/data/couchbase/core/ReactiveRemoveByIdOperationSupport.java @@ -157,7 +157,7 @@ public class ReactiveRemoveByIdOperationSupport implements ReactiveRemoveByIdOpe public Mono oneEntity(Object entity) { ReactiveRemoveByIdSupport op = new ReactiveRemoveByIdSupport(template, domainType, scope, collection, options, persistTo, replicateTo, durabilityLevel, template.support().getCas(entity)); - return op.one(template.support().getId(entity).toString()); + return op.withCas(template.support().getCas(entity)).one(template.support().getId(entity).toString()); } @Override