Correct the self usage in ThreePhaseCommitCohort 76/10076/3
authorBasheeruddin Ahmed <syedbahm@cisco.com>
Tue, 19 Aug 2014 19:42:15 +0000 (12:42 -0700)
committerBasheeruddin Ahmed <syedbahm@cisco.com>
Wed, 20 Aug 2014 17:16:53 +0000 (10:16 -0700)
Seems this correction missed from another commit

Change-Id: Iacd8055b0e59238cf3377f250de0f0e17f4e3e98
Signed-off-by: Basheeruddin Ahmed <syedbahm@cisco.com>
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ThreePhaseCommitCohort.java

index 25705bff418740c873af8334091b3961612c3f1e..34d35312838fd4346e7446161cd4f1f1c8f9cc74 100644 (file)
@@ -90,7 +90,7 @@ public class ThreePhaseCommitCohort extends AbstractUntypedActor {
             public void onFailure(Throwable t) {
                 LOG.error(t, "An exception happened during abort");
                 sender
-                    .tell(new akka.actor.Status.Failure(t), getSelf());
+                    .tell(new akka.actor.Status.Failure(t), self);
             }
         });
     }
@@ -119,7 +119,7 @@ public class ThreePhaseCommitCohort extends AbstractUntypedActor {
             public void onFailure(Throwable t) {
                 LOG.error(t, "An exception happened during pre-commit");
                 sender
-                    .tell(new akka.actor.Status.Failure(t), getSelf());
+                    .tell(new akka.actor.Status.Failure(t), self);
             }
         });
 
@@ -138,7 +138,7 @@ public class ThreePhaseCommitCohort extends AbstractUntypedActor {
             public void onFailure(Throwable t) {
                 LOG.error(t, "An exception happened during canCommit");
                 sender
-                    .tell(new akka.actor.Status.Failure(t), getSelf());
+                    .tell(new akka.actor.Status.Failure(t), self);
             }
         });