super(cohort);
this.subtree = Preconditions.checkNotNull(subtree);
this.actorContext = Preconditions.checkNotNull(actorContext);
- this.actor = actorContext.getActorSystem().actorOf(
- DataTreeCohortActor.props(getInstance()).withDispatcher(actorContext.getNotificationDispatcherPath()));
+ this.actor = actorContext.getActorSystem().actorOf(DataTreeCohortActor.props(getInstance(),
+ subtree.getRootIdentifier()).withDispatcher(actorContext.getNotificationDispatcherPath()));
}
future.onComplete(new OnComplete<Object>() {
@Override
- public void onComplete(Throwable e, Object val) throws Throwable {
- if (e != null) {
- LOG.error("Unable to register {} as commit cohort", getInstance(), e);
+ public void onComplete(Throwable failure, Object val) {
+ if (failure != null) {
+ LOG.error("Unable to register {} as commit cohort", getInstance(), failure);
}
if (isClosed()) {
removeRegistration();