- public void registerTreeChangeListener(YangInstanceIdentifier treeId,
- DOMDataTreeChangeListener listener, Optional<DataTreeCandidate> currentState,
- Consumer<ListenerRegistration<DOMDataTreeChangeListener>> onRegistration) {
- notifierActor().tell(new ShardDataTreeChangePublisherActor.RegisterListener(treeId, listener, currentState,
- onRegistration), ActorRef.noSender());
+ public void registerTreeChangeListener(final YangInstanceIdentifier treeId,
+ final DOMDataTreeChangeListener listener, final Optional<DataTreeCandidate> currentState,
+ final Consumer<ListenerRegistration<DOMDataTreeChangeListener>> onRegistration) {
+ final ShardDataTreeChangePublisherActor.RegisterListener regMessage =
+ new ShardDataTreeChangePublisherActor.RegisterListener(treeId, listener, currentState, onRegistration);
+ log.debug("{}: Sending {} to publisher actor {}", logContext(), regMessage, publisherActor());
+ publisherActor().tell(regMessage, ActorRef.noSender());