extends ShardDataTreeNotificationPublisherActor<ShardDataChangeListenerPublisher> {
private ShardDataChangePublisherActor(final String name, final String logContext) {
extends ShardDataTreeNotificationPublisherActor<ShardDataChangeListenerPublisher> {
private ShardDataChangePublisherActor(final String name, final String logContext) {
RegisterListener reg = (RegisterListener)message;
if (reg.initialState.isPresent()) {
DefaultShardDataChangeListenerPublisher.notifySingleListener(reg.path, reg.listener, reg.scope,
RegisterListener reg = (RegisterListener)message;
if (reg.initialState.isPresent()) {
DefaultShardDataChangeListenerPublisher.notifySingleListener(reg.path, reg.listener, reg.scope,
}
publisher().registerDataChangeListener(reg.path, reg.listener, reg.scope, Optional.absent(),
}
publisher().registerDataChangeListener(reg.path, reg.listener, reg.scope, Optional.absent(),