GEODE-1106 test was setting testHook asynchronously. Now it set synchronously.
That was causing other thread to not to use testhook Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/8c690ac6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/8c690ac6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/8c690ac6 Branch: refs/heads/feature/GEODE-1050 Commit: 8c690ac6ab4e968f404031f2ece8f1b89c7ff9a5 Parents: 9993c76 Author: Hitesh Khamesra <[email protected]> Authored: Fri Mar 18 09:19:12 2016 -0700 Committer: Hitesh Khamesra <[email protected]> Committed: Fri Mar 18 09:23:23 2016 -0700 ---------------------------------------------------------------------- .../tier/sockets/DurableClientSimpleDUnitTest.java | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8c690ac6/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DurableClientSimpleDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DurableClientSimpleDUnitTest.java b/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DurableClientSimpleDUnitTest.java index 766fad5..0a263eb 100644 --- a/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DurableClientSimpleDUnitTest.java +++ b/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DurableClientSimpleDUnitTest.java @@ -2856,16 +2856,21 @@ public class DurableClientSimpleDUnitTest extends DurableClientTestCase { startClient(publisherClientVM, serverPort, regionName); // Publish some entries - publishEntries(publisherClientVM, regionName, 10); + publishEntries(publisherClientVM, regionName, 10); + + this.server1VM.invoke(new CacheSerializableRunnable( + "Set test hook") { + public void run2() throws CacheException { + //Set the Test Hook! + //This test hook will pause during the drain process + CacheClientProxy.testHook = new RejectClientReconnectTestHook(); + } + }); this.server1VM.invokeAsync(new CacheSerializableRunnable( "Close cq for durable client") { public void run2() throws CacheException { - //Set the Test Hook! - //This test hook will pause during the drain process - CacheClientProxy.testHook = new RejectClientReconnectTestHook(); - final CacheClientNotifier ccnInstance = CacheClientNotifier .getInstance(); final CacheClientProxy clientProxy = ccnInstance
