Skip to content

Commit 771a81c

Browse files
authored
Merge pull request #33 from PlaytikaOSS/feature/remove-redundand-policy
Remove redundant checkValuesPolicy
2 parents 1d4694a + 4f66694 commit 771a81c

File tree

2 files changed

+0
-11
lines changed

2 files changed

+0
-11
lines changed

aerospike-batch-updater/src/main/java/nosql/batch/update/aerospike/lock/AerospikeLockOperations.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -35,11 +35,6 @@ public class AerospikeLockOperations<LOCKS extends AerospikeBatchLocks<EV>, EV>
3535

3636
private static final String BATCH_ID_BIN_NAME = "batch_id";
3737

38-
private static final WritePolicy checkValuesPolicy = new WritePolicy();
39-
static {
40-
checkValuesPolicy.respondAllOps = true;
41-
}
42-
4338
private final IAerospikeClient aerospikeClient;
4439
private final WritePolicy putLockPolicy;
4540
private final WritePolicy deleteLockPolicy;

aerospike-reactor-batch-updater/src/main/java/nosql/batch/update/reactor/aerospike/lock/AerospikeReactorLockOperations.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@
1212
import nosql.batch.update.aerospike.lock.AerospikeBatchLocks;
1313
import nosql.batch.update.aerospike.lock.AerospikeLock;
1414
import nosql.batch.update.lock.LockingException;
15-
import nosql.batch.update.lock.PermanentLockingException;
1615
import nosql.batch.update.lock.TemporaryLockingException;
1716
import nosql.batch.update.reactor.lock.ReactorLockOperations;
1817
import org.slf4j.Logger;
@@ -34,11 +33,6 @@ public class AerospikeReactorLockOperations<LOCKS extends AerospikeBatchLocks<EV
3433

3534
private static final String BATCH_ID_BIN_NAME = "batch_id";
3635

37-
private static final WritePolicy checkValuesPolicy = new WritePolicy();
38-
static {
39-
checkValuesPolicy.respondAllOps = true;
40-
}
41-
4236
private final IAerospikeReactorClient reactorClient;
4337
private final WritePolicy putLockPolicy;
4438
private final WritePolicy deleteLockPolicy;

0 commit comments

Comments
 (0)