*/
package org.opendaylight.netconf.mdsal.notification.impl;
-import com.google.common.base.Preconditions;
+import static com.google.common.base.Preconditions.checkArgument;
+import static com.google.common.base.Preconditions.checkState;
+import static java.util.Objects.requireNonNull;
+
import com.google.common.collect.HashMultimap;
import com.google.common.collect.HashMultiset;
import com.google.common.collect.Lists;
import com.google.common.collect.Multimap;
import com.google.common.collect.Multiset;
+import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
public synchronized NotificationListenerRegistration registerNotificationListener(
final StreamNameType stream,
final NetconfNotificationListener listener) {
- Preconditions.checkNotNull(stream);
- Preconditions.checkNotNull(listener);
+ requireNonNull(stream);
+ requireNonNull(listener);
LOG.trace("Notification listener registered for stream: {}", stream);
@Override
public synchronized NotificationPublisherRegistration registerNotificationPublisher(final Stream stream) {
- Preconditions.checkNotNull(stream);
- final StreamNameType streamName = stream.getName();
+ final StreamNameType streamName = requireNonNull(stream).getName();
LOG.debug("Notification publisher registered for stream: {}", streamName);
if (LOG.isTraceEnabled()) {
return genericNotificationPublisherReg;
}
+ @SuppressFBWarnings(value = "UPM_UNCALLED_PRIVATE_METHOD",
+ justification = "https://github.com/spotbugs/spotbugs/issues/811")
private void unregisterNotificationPublisher(
final StreamNameType streamName,
final GenericNotificationPublisherReg genericNotificationPublisherReg) {
@Override
public void onNotification(final StreamNameType stream, final NetconfNotification notification) {
- Preconditions.checkState(baseListener != null, "Already closed");
- Preconditions.checkArgument(stream.equals(registeredStream));
+ checkState(baseListener != null, "Already closed");
+ checkArgument(stream.equals(registeredStream));
baseListener.onNotification(stream, notification);
}
}