You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by bo...@apache.org on 2016/03/29 18:06:31 UTC
incubator-geode git commit: GEODE-1131: ParallelGatewaySenderQueue
destroyEventFromQueue now handles RegionDestroyedException
Repository: incubator-geode
Updated Branches:
refs/heads/develop c36591b73 -> 82b325ee2
GEODE-1131: ParallelGatewaySenderQueue destroyEventFromQueue now handles RegionDestroyedException
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/82b325ee
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/82b325ee
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/82b325ee
Branch: refs/heads/develop
Commit: 82b325ee27ede54a53e8c0efb39ed6722d6128b3
Parents: c36591b
Author: Barry Oglesby <bo...@pivotal.io>
Authored: Mon Mar 28 17:51:20 2016 -0700
Committer: Barry Oglesby <bo...@pivotal.io>
Committed: Tue Mar 29 09:06:22 2016 -0700
----------------------------------------------------------------------
.../internal/cache/wan/parallel/ParallelGatewaySenderQueue.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/82b325ee/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelGatewaySenderQueue.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelGatewaySenderQueue.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelGatewaySenderQueue.java
index a9d0f3e..b4efd21 100644
--- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelGatewaySenderQueue.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelGatewaySenderQueue.java
@@ -54,6 +54,7 @@ import com.gemstone.gemfire.cache.EvictionAttributes;
import com.gemstone.gemfire.cache.PartitionAttributesFactory;
import com.gemstone.gemfire.cache.Region;
import com.gemstone.gemfire.cache.RegionAttributes;
+import com.gemstone.gemfire.cache.RegionDestroyedException;
import com.gemstone.gemfire.cache.asyncqueue.internal.AsyncEventQueueImpl;
import com.gemstone.gemfire.distributed.internal.DM;
import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem;
@@ -1149,6 +1150,10 @@ public class ParallelGatewaySenderQueue implements RegionQueue {
if (logger.isDebugEnabled()) {
logger.debug("Primary bucket :{} moved to other member", bucketId);
}
+ } catch (RegionDestroyedException e) {
+ if (logger.isDebugEnabled()) {
+ logger.debug("Caught RegionDestroyedException attempting to remove key {} from bucket {} in {}", key, bucketId, prQ.getFullPath());
+ }
}
addRemovedEvent(prQ, bucketId, key);
}