Merge pull request #43 from caskdata/feature/expose-current-tx

TEPHRA-79 Allow access to current transaction
cdapio · Mar 12, 2015 · b0aef8b · b0aef8b
2 parents 081a556 + 65f6b36
commit b0aef8b
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/tephra-core/src/main/java/co/cask/tephra/TransactionContext.java b/tephra-core/src/main/java/co/cask/tephra/TransactionContext.java
@@ -23,6 +23,7 @@
 import org.slf4j.LoggerFactory;
 
 import java.util.Collection;
+import javax.annotation.Nullable;
 
 /**
  * Utility class that encapsulates the transaction life cycle over a given set of
@@ -86,6 +87,13 @@ public void abort() throws TransactionFailureException {
     abort(null);
   }
 
+  /**
+   * Returns the current transaction or null if no transaction is currently in progress.
+   */
+  @Nullable
+  public Transaction getCurrentTransaction() {
+    return currentTx;
+  }
 
   // CHECKSTYLE IGNORE "@throws" FOR 11 LINES
   /**