[geode] branch feature/GEODE-5528 updated: GEODE-5528: client event listener invoked multiple times for the same transactional operation

[bschuchardt]

This is an automated email from the ASF dual-hosted git repository.

bschuchardt pushed a commit to branch feature/GEODE-5528
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/feature/GEODE-5528 by this 
push:
     new 8f577ef  GEODE-5528: client event listener invoked multiple times for 
the same transactional operation
8f577ef is described below

commit 8f577efa6d48582736fb2c202493098df8c223af
Author: Bruce Schuchardt <bschucha...@pivotal.io>
AuthorDate: Fri Aug 3 15:55:08 2018 -0700

    GEODE-5528: client event listener invoked multiple times for the same 
transactional operation
    
    Missed this file in the initial commit.
---
 .../apache/geode/internal/cache/RemoteTransactionDUnitTest.java    | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/RemoteTransactionDUnitTest.java
 
b/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/RemoteTransactionDUnitTest.java
index fd2f193..2d1dcff 100644
--- 
a/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/RemoteTransactionDUnitTest.java
+++ 
b/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/RemoteTransactionDUnitTest.java
@@ -47,7 +47,9 @@ import org.junit.Test;
 import org.apache.geode.ExpirationDetector;
 import org.apache.geode.cache.AttributesFactory;
 import org.apache.geode.cache.AttributesMutator;
+import org.apache.geode.cache.CacheClosedException;
 import org.apache.geode.cache.CacheEvent;
+import org.apache.geode.cache.CacheFactory;
 import org.apache.geode.cache.CacheListener;
 import org.apache.geode.cache.CacheLoader;
 import org.apache.geode.cache.CacheLoaderException;
@@ -133,6 +135,11 @@ public class RemoteTransactionDUnitTest extends 
JUnit4CacheTestCase {
   private final SerializableCallable verifyNoTxState = new 
SerializableCallable() {
     @Override
     public Object call() throws Exception {
+      try {
+        CacheFactory.getAnyInstance();
+      } catch (CacheClosedException e) {
+        return null;
+      }
       // TXManagerImpl mgr = getGemfireCache().getTxManager();
       // assertIndexDetailsEquals(0, 
mgr.hostedTransactionsInProgressForTest());
       final TXManagerImpl mgr = getGemfireCache().getTxManager();