import akka.dispatch.ExecutionContexts;
import akka.dispatch.Futures;
import akka.dispatch.OnComplete;
+import com.google.common.base.MoreObjects.ToStringHelper;
import com.google.common.base.Preconditions;
import com.google.common.base.Verify;
import com.google.common.primitives.UnsignedLong;
void throwCanCommitFailure() throws Exception {
throw failure;
}
+
+ @Override
+ ToStringHelper addToStringAttributes(final ToStringHelper toStringHelper) {
+ return super.addToStringAttributes(toStringHelper).add("failure", failure);
+ }
}
static final class Normal extends SimpleShardDataTreeCohort {
public boolean isFailed() {
return state == State.FAILED || nextFailure != null;
}
+
+ @Override
+ ToStringHelper addToStringAttributes(final ToStringHelper toStringHelper) {
+ return super.addToStringAttributes(toStringHelper).add("nextFailure", nextFailure);
+ }
}