geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jinmeil...@apache.org
Subject [40/64] [abbrv] incubator-geode git commit: GEODE-1131: ParallelGatewaySenderQueue destroyEventFromQueue now handles RegionDestroyedException
Date Thu, 31 Mar 2016 15:23:03 GMT
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/feature/GEODE-17-2
Commit: 82b325ee27ede54a53e8c0efb39ed6722d6128b3
Parents: c36591b
Author: Barry Oglesby <boglesby@pivotal.io>
Authored: Mon Mar 28 17:51:20 2016 -0700
Committer: Barry Oglesby <boglesby@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);
     }


Mime
View raw message