*/
package org.opendaylight.openflowplugin.openflow.md.core;
-import org.opendaylight.openflowplugin.openflow.md.queue.PopListener;
+import org.opendaylight.openflowplugin.api.openflow.md.queue.PopListener;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* @author mirehak
*/
public class PopListenerCountingImpl<T> implements PopListener<T> {
+ private static final Logger LOG = LoggerFactory
+ .getLogger(PopListenerCountingImpl.class);
private int count = 0;
@Override
public synchronized void onPop(T processedMessage) {
- count ++;
+ LOG.debug("message popped: {}", processedMessage);
+ count += 1;
notify();
}