Repository: incubator-tephra Updated Branches: refs/heads/master 14858e4af -> 66354786d
Add methods to help testing Transaction Manager This closes #11 Signed-off-by: poorna <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/incubator-tephra/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-tephra/commit/66354786 Tree: http://git-wip-us.apache.org/repos/asf/incubator-tephra/tree/66354786 Diff: http://git-wip-us.apache.org/repos/asf/incubator-tephra/diff/66354786 Branch: refs/heads/master Commit: 66354786dab76b9c4b7ce3922c9288baad2c07c7 Parents: 14858e4 Author: poorna <[email protected]> Authored: Mon Sep 12 18:25:49 2016 -0700 Committer: poorna <[email protected]> Committed: Mon Sep 12 18:54:23 2016 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/tephra/TransactionManager.java | 7 +++++++ .../org/apache/tephra/distributed/TransactionService.java | 8 ++++++++ 2 files changed, 15 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-tephra/blob/66354786/tephra-core/src/main/java/org/apache/tephra/TransactionManager.java ---------------------------------------------------------------------- diff --git a/tephra-core/src/main/java/org/apache/tephra/TransactionManager.java b/tephra-core/src/main/java/org/apache/tephra/TransactionManager.java index cfefc83..e3cd2f8 100644 --- a/tephra-core/src/main/java/org/apache/tephra/TransactionManager.java +++ b/tephra-core/src/main/java/org/apache/tephra/TransactionManager.java @@ -18,6 +18,7 @@ package org.apache.tephra; +import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Objects; import com.google.common.base.Preconditions; import com.google.common.base.Stopwatch; @@ -1265,6 +1266,12 @@ public class TransactionManager extends AbstractService { ", committed = " + committedChangeSets.size()); } + @SuppressWarnings("unused") + @VisibleForTesting + public TransactionStateStorage getTransactionStateStorage() { + return persistor; + } + private abstract static class DaemonThreadExecutor extends Thread { private AtomicBoolean stopped = new AtomicBoolean(false); http://git-wip-us.apache.org/repos/asf/incubator-tephra/blob/66354786/tephra-core/src/main/java/org/apache/tephra/distributed/TransactionService.java ---------------------------------------------------------------------- diff --git a/tephra-core/src/main/java/org/apache/tephra/distributed/TransactionService.java b/tephra-core/src/main/java/org/apache/tephra/distributed/TransactionService.java index 6fbf926..4061c4d 100644 --- a/tephra-core/src/main/java/org/apache/tephra/distributed/TransactionService.java +++ b/tephra-core/src/main/java/org/apache/tephra/distributed/TransactionService.java @@ -42,6 +42,7 @@ import java.net.UnknownHostException; import java.util.concurrent.ExecutionException; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; +import javax.annotation.Nullable; /** * @@ -153,4 +154,11 @@ public final class TransactionService extends InMemoryTransactionService { } } } + + @SuppressWarnings({"WeakerAccess", "unused"}) + @VisibleForTesting + @Nullable + public TransactionManager getTransactionManager() { + return txManager; + } }
