@@ -0,0 +1,997 @@
+package com.playtika.test.aerospike;%0A%0Aimport com.aerospike.client.AerospikeException;%0Aimport com.aerospike.client.Key;%0Aimport com.aerospike.client.policy.Policy;%0Aimport com.playtika.test.common.operations.NetworkTestOperations;%0Aimport org.junit.jupiter.api.Test;%0Aimport org.springframework.beans.factory.annotation.Autowired;%0A%0Aimport java.time.Duration;%0A%0Aimport static org.assertj.core.api.Assertions.assertThatThrownBy;%0A%0Apublic class NetworkTestOperationsTest extends BaseAerospikeTest %7B%0A%0A    @Autowired%0A    NetworkTestOperations networkTestOperations;%0A%0A    @Test%0A    void validateNetworkLatencyIsApplied() %7B%0A        networkTestOperations.withNetworkLatency(Duration.ofSeconds(5), () -%3E %7B%0A            Policy policy = new Policy(client.getReadPolicyDefault());%0A            policy.setTimeout(100);//in millis%0A%0A            assertThatThrownBy(() -%3E client.get(policy, new Key(namespace, %22any-set%22, %22any-key%22)))%0A                    .isInstanceOf(AerospikeException.Timeout.class);%0A        %7D);%0A    %7D%0A%7D%0A

Add test for network latency (#760)