Migrate Queue stats collection

[yangtools.git] / common / util / src / main / java / org / opendaylight / yangtools / util / concurrent / AbstractQueuedNotificationManager.java

diff --git a/common/util/src/main/java/org/opendaylight/yangtools/util/concurrent/AbstractQueuedNotificationManager.java b/common/util/src/main/java/org/opendaylight/yangtools/util/concurrent/AbstractQueuedNotificationManager.java
index 50f78373b000f09f5ed634ed3038385cc77a2c6d..50cabef0aafa8e5fa92f08b9bf3fffff76fd8932 100644 (file)
--- a/common/util/src/main/java/org/opendaylight/yangtools/util/concurrent/AbstractQueuedNotificationManager.java
+++ b/common/util/src/main/java/org/opendaylight/yangtools/util/concurrent/AbstractQueuedNotificationManager.java
@@ -10,9 +10,7 @@ package org.opendaylight.yangtools.util.concurrent;
 import static java.util.Objects.requireNonNull;
 
 import com.google.common.collect.ImmutableList;
-import java.util.List;
 import java.util.concurrent.Executor;
-import java.util.stream.Collectors;
 import org.eclipse.jdt.annotation.NonNull;
 import org.eclipse.jdt.annotation.NonNullByDefault;
 import org.eclipse.jdt.annotation.Nullable;
@@ -71,16 +69,6 @@ abstract class AbstractQueuedNotificationManager<T, L, N> extends AbstractBatchi
         return mxBean;
     }
 
-    /**
-     * Returns {@link ListenerNotificationQueueStats} instances for each current listener
-     * notification task in progress.
-     */
-    // FIXME: drop visibility to package-protected
-    public final List<ListenerNotificationQueueStats> getListenerNotificationQueueStats() {
-        return streamTasks().map(t -> new ListenerNotificationQueueStats(t.key().toString(), t.size()))
-                .collect(Collectors.toList());
-    }
-
     @Override
     public final void submitNotification(final L listener, final N notification) {
         if (listener != null && notification != null) {