- public ShardDataChangeListenerPublisher newInstance() {
- return new ShardDataChangeListenerPublisherActorProxy(this);
+ public void registerDataChangeListener(YangInstanceIdentifier path,
+ AsyncDataChangeListener<YangInstanceIdentifier, NormalizedNode<?, ?>> listener, DataChangeScope scope,
+ Optional<DataTreeCandidate> initialState,
+ Consumer<ListenerRegistration<AsyncDataChangeListener<YangInstanceIdentifier, NormalizedNode<?, ?>>>>
+ onRegistration) {
+ publisherActor().tell(new ShardDataChangePublisherActor.RegisterListener(path, listener, scope, initialState,
+ onRegistration), ActorRef.noSender());