Update TestNonBlockingStore.java

mgamanho · Sep 26, 2024 · 7378755 · 7378755
1 parent dd9a140
commit 7378755
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ence-testing-support/src/main/java/com/oracle/coherence/testing/TestNonBlockingStore.java b/...ence-testing-support/src/main/java/com/oracle/coherence/testing/TestNonBlockingStore.java
@@ -316,10 +316,10 @@ public void store(BinaryEntry<K, V> binEntry, StoreObserver<K, V> observer)
 
                 log("**MG** store thread[" + Thread.currentThread().getName() + "] delay duration: " + getDurationStore());
         log("**MG** TestNonBlockingStore store binEntry hashcode(2): " + binEntry.getBinaryValue().hashCode());
+                delay(200);
                 delay(getDurationStore());
                 getStorageMap().put(oKey, oValue);
                 getProcessor().process(binEntry);
-                delay(200);
         log("**MG** TestNonBlockingStore store binEntry hashcode(3): " + binEntry.getBinaryValue().hashCode());
                 log("**MG** store thread[" + Thread.currentThread().getName() + "] calling onNext");
                 observer.onNext(binEntry);