*/
package org.opendaylight.controller.messagebus.app.impl;
-import com.google.common.base.Preconditions;
+import static java.util.Objects.requireNonNull;
+
import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
import java.util.concurrent.CopyOnWriteArraySet;
import java.util.concurrent.ExecutionException;
import java.util.regex.Pattern;
-import javax.annotation.Nonnull;
import org.opendaylight.mdsal.binding.api.DataObjectModification;
import org.opendaylight.mdsal.binding.api.DataTreeChangeListener;
import org.opendaylight.mdsal.binding.api.DataTreeIdentifier;
private EventSourceTopic(final NotificationPattern notificationPattern, final String nodeIdRegexPattern,
final EventSourceService sourceService) {
- this.notificationPattern = Preconditions.checkNotNull(notificationPattern);
- this.sourceService = Preconditions.checkNotNull(sourceService);
+ this.notificationPattern = requireNonNull(notificationPattern);
+ this.sourceService = requireNonNull(sourceService);
this.nodeIdPattern = Pattern.compile(nodeIdRegexPattern);
this.topicId = new TopicId(getUUIDIdent());
this.listenerRegistration = null;
Futures.addCallback(future, new FutureCallback<Optional<Topology>>() {
@Override
- public void onSuccess(@Nonnull final Optional<Topology> data) {
+ public void onSuccess(final Optional<Topology> data) {
if (data.isPresent()) {
final List<Node> nodes = data.get().getNode();
if (nodes != null) {