You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by la...@apache.org on 2018/12/17 21:50:58 UTC
[geode] 04/04: GEODE-6177: make test hook visible across threads
This is an automated email from the ASF dual-hosted git repository.
ladyvader pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git
commit 213e07ff7910d33073e9d933ded252cc9fc0b881
Author: Ryan McMahon <rm...@pivotal.io>
AuthorDate: Mon Dec 17 09:33:57 2018 -0800
GEODE-6177: make test hook visible across threads
---
.../geode/internal/cache/wan/GatewaySenderEventRemoteDispatcher.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/geode-wan/src/main/java/org/apache/geode/internal/cache/wan/GatewaySenderEventRemoteDispatcher.java b/geode-wan/src/main/java/org/apache/geode/internal/cache/wan/GatewaySenderEventRemoteDispatcher.java
index 3b3318f..a0b714d 100644
--- a/geode-wan/src/main/java/org/apache/geode/internal/cache/wan/GatewaySenderEventRemoteDispatcher.java
+++ b/geode-wan/src/main/java/org/apache/geode/internal/cache/wan/GatewaySenderEventRemoteDispatcher.java
@@ -67,7 +67,7 @@ public class GatewaySenderEventRemoteDispatcher implements GatewaySenderEventDis
* Without this hook, negative tests, can't ensure that message processing was
* attempted, so they wouldn't know how long to wait for some sort of failure.
*/
- public static Consumer<Boolean> messageProcessingAttempted = isAck -> {
+ public static volatile Consumer<Boolean> messageProcessingAttempted = isAck -> {
};
/**