Optional<DataTreeCandidate> initialState,
Consumer<ListenerRegistration<AsyncDataChangeListener<YangInstanceIdentifier, NormalizedNode<?, ?>>>>
onRegistration) {
Optional<DataTreeCandidate> initialState,
Consumer<ListenerRegistration<AsyncDataChangeListener<YangInstanceIdentifier, NormalizedNode<?, ?>>>>
onRegistration) {
- notifierActor().tell(new ShardDataChangePublisherActor.RegisterListener(path, listener, scope, initialState,
+ publisherActor().tell(new ShardDataChangePublisherActor.RegisterListener(path, listener, scope, initialState,