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-3109 Commit: 1a8848974dd685590e548d84035555c2c6eb3fe1 Parents: 0254a60 Author: eshu <e...@pivotal.io> Authored: Wed Jun 28 11:08:30 2017 -0700 Committer: eshu <e...@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 {
