You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by kl...@apache.org on 2017/07/06 18:26:57 UTC
[23/50] [abbrv] geode git commit: GEODE-3132 EndBucketCreationMessage
will not participate in a transaction.
GEODE-3132 EndBucketCreationMessage will not participate in a transaction.
Project: http://git-wip-us.apache.org/repos/asf/geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/1a884897
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/1a884897
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/1a884897
Branch: refs/heads/feature/GEODE-1279
Commit: 1a8848974dd685590e548d84035555c2c6eb3fe1
Parents: 0254a60
Author: eshu <es...@pivotal.io>
Authored: Wed Jun 28 11:08:30 2017 -0700
Committer: eshu <es...@pivotal.io>
Committed: Wed Jun 28 11:09:49 2017 -0700
----------------------------------------------------------------------
.../internal/cache/partitioned/EndBucketCreationMessage.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/geode/blob/1a884897/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/EndBucketCreationMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/EndBucketCreationMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/EndBucketCreationMessage.java
index 355c3b5..84cc845 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/EndBucketCreationMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/EndBucketCreationMessage.java
@@ -90,6 +90,11 @@ public class EndBucketCreationMessage extends PartitionMessage {
}
@Override
+ public boolean canParticipateInTransaction() {
+ return false;
+ }
+
+ @Override
protected boolean operateOnPartitionedRegion(DistributionManager dm, PartitionedRegion region,
long startTime) throws ForceReattemptException {