import org.opendaylight.yangtools.concepts.ListenerRegistration;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
import org.opendaylight.yangtools.concepts.ListenerRegistration;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
-public class ShardDataTreeChangePublisherActor
- extends ShardDataTreeNotificationPublisherActor<ShardDataTreeChangeListenerPublisher> {
+public final class ShardDataTreeChangePublisherActor
+ extends ShardDataTreeNotificationPublisherActor<DefaultShardDataTreeChangeListenerPublisher> {
private ShardDataTreeChangePublisherActor(final String name, final String logContext) {
super(new DefaultShardDataTreeChangeListenerPublisher(logContext), name, logContext);
}
@Override
private ShardDataTreeChangePublisherActor(final String name, final String logContext) {
super(new DefaultShardDataTreeChangeListenerPublisher(logContext), name, logContext);
}
@Override
if (message instanceof RegisterListener) {
RegisterListener reg = (RegisterListener)message;
LOG.debug("{}: Received {}", logContext(), reg);
if (reg.initialState.isPresent()) {
DefaultShardDataTreeChangeListenerPublisher.notifySingleListener(reg.path, reg.listener,
reg.initialState.get(), logContext());
if (message instanceof RegisterListener) {
RegisterListener reg = (RegisterListener)message;
LOG.debug("{}: Received {}", logContext(), reg);
if (reg.initialState.isPresent()) {
DefaultShardDataTreeChangeListenerPublisher.notifySingleListener(reg.path, reg.listener,
reg.initialState.get(), logContext());
- publisher().registerTreeChangeListener(reg.path, reg.listener, Optional.absent(), reg.onRegistration);
+ publisher().registerTreeChangeListener(reg.path, reg.listener, reg.onRegistration);
RegisterListener(final YangInstanceIdentifier path, final DOMDataTreeChangeListener listener,
final Optional<DataTreeCandidate> initialState,
final Consumer<ListenerRegistration<DOMDataTreeChangeListener>> onRegistration) {
RegisterListener(final YangInstanceIdentifier path, final DOMDataTreeChangeListener listener,
final Optional<DataTreeCandidate> initialState,
final Consumer<ListenerRegistration<DOMDataTreeChangeListener>> onRegistration) {
- this.path = Preconditions.checkNotNull(path);
- this.listener = Preconditions.checkNotNull(listener);
- this.initialState = Preconditions.checkNotNull(initialState);
- this.onRegistration = Preconditions.checkNotNull(onRegistration);
+ this.path = requireNonNull(path);
+ this.listener = requireNonNull(listener);
+ this.initialState = requireNonNull(initialState);
+ this.onRegistration = requireNonNull(onRegistration);