From 4f6669446907ee620932089b0554368fb2bc2936 Mon Sep 17 00:00:00 2001 From: skarpenko Date: Tue, 9 Apr 2024 18:32:14 +0200 Subject: [PATCH] Remove redundant checkValuesPolicy --- .../update/aerospike/lock/AerospikeLockOperations.java | 5 ----- .../aerospike/lock/AerospikeReactorLockOperations.java | 6 ------ 2 files changed, 11 deletions(-) diff --git a/aerospike-batch-updater/src/main/java/nosql/batch/update/aerospike/lock/AerospikeLockOperations.java b/aerospike-batch-updater/src/main/java/nosql/batch/update/aerospike/lock/AerospikeLockOperations.java index 0dd0e5d..0c67151 100644 --- a/aerospike-batch-updater/src/main/java/nosql/batch/update/aerospike/lock/AerospikeLockOperations.java +++ b/aerospike-batch-updater/src/main/java/nosql/batch/update/aerospike/lock/AerospikeLockOperations.java @@ -35,11 +35,6 @@ public class AerospikeLockOperations, EV> private static final String BATCH_ID_BIN_NAME = "batch_id"; - private static final WritePolicy checkValuesPolicy = new WritePolicy(); - static { - checkValuesPolicy.respondAllOps = true; - } - private final IAerospikeClient aerospikeClient; private final WritePolicy putLockPolicy; private final WritePolicy deleteLockPolicy; diff --git a/aerospike-reactor-batch-updater/src/main/java/nosql/batch/update/reactor/aerospike/lock/AerospikeReactorLockOperations.java b/aerospike-reactor-batch-updater/src/main/java/nosql/batch/update/reactor/aerospike/lock/AerospikeReactorLockOperations.java index bb64563..5170e26 100644 --- a/aerospike-reactor-batch-updater/src/main/java/nosql/batch/update/reactor/aerospike/lock/AerospikeReactorLockOperations.java +++ b/aerospike-reactor-batch-updater/src/main/java/nosql/batch/update/reactor/aerospike/lock/AerospikeReactorLockOperations.java @@ -12,7 +12,6 @@ import nosql.batch.update.aerospike.lock.AerospikeBatchLocks; import nosql.batch.update.aerospike.lock.AerospikeLock; import nosql.batch.update.lock.LockingException; -import nosql.batch.update.lock.PermanentLockingException; import nosql.batch.update.lock.TemporaryLockingException; import nosql.batch.update.reactor.lock.ReactorLockOperations; import org.slf4j.Logger; @@ -34,11 +33,6 @@ public class AerospikeReactorLockOperations