Merge pull request #31 from caskdata/feature/tephra-47_service-abort

TEPHRA-47 Pass along cause of TransactionManager abort

tephra-core/src/main/java/co/cask/tephra/distributed/TransactionService.java

@@ -73,7 +73,7 @@ public void leader() {
           @Override
           public void failed(State from, Throwable failure) {
             LOG.error("Transaction manager aborted, stopping transaction service");
-            stopAndWait();
+            TransactionService.this.abort(failure);
           }
         }, MoreExecutors.sameThreadExecutor());
 
@@ -109,6 +109,17 @@ public void follower() {
 
   @Override
   protected void doStop() {
+    internalStop();
+    notifyStopped();
+  }
+
+  protected void abort(Throwable cause) {
+    // try to clear leader status and shutdown RPC
+    internalStop();
+    notifyFailed(cause);
+  }
+
+  protected void internalStop() {
     if (leaderElection != null) {
       // NOTE: if was a leader this will cause loosing of leadership which in callback above will
       //       de-register service in discovery service and stop the service if needed
@@ -120,7 +131,5 @@ protected void doStop() {
         LOG.error("Exception when cancelling leader election.", e);
       }
     }
-
-    notifyStopped();
   }
 }