- ForwardingDataTreeChangeListener(final ActorSelection actor) {
- this.actor = Preconditions.checkNotNull(actor, "actor should not be null");
+ @Override
+ public void onDataTreeChanged(final Collection<DataTreeCandidate> changes) {
+ LOG.debug("Sending DataTreeChanged to {}", actor);
+ actor.tell(new DataTreeChanged(changes), sendingActor);
+ }
+
+ @Override
+ public void onInitialData() {
+ LOG.debug("Sending OnInitialData to {}", actor);
+ actor.tell(OnInitialData.INSTANCE, sendingActor);