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 <[email protected]> Authored: Mon Mar 28 17:51:20 2016 -0700 Committer: Barry Oglesby <[email protected]> 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); }
