You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by bs...@apache.org on 2018/08/03 22:55:53 UTC
[geode] branch feature/GEODE-5528 updated: GEODE-5528: client event
listener invoked multiple times for the same transactional operation
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 <bs...@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();