import java.util.concurrent.TimeoutException;
import org.opendaylight.openflowplugin.openflow.md.core.sal.OFRpcTask;
-import org.opendaylight.openflowplugin.openflow.md.queue.MessageSpy;
+import org.opendaylight.openflowplugin.api.openflow.statistics.MessageSpy;
import org.opendaylight.yangtools.yang.binding.DataContainer;
import com.google.common.util.concurrent.ListenableFuture;
private DataContainer notSupportedTask = new NoDataContainerTask();
/**
- * @param executorService
+ * @param executorService executor service
*/
public RpcListeningExecutorService(ListeningExecutorService executorService) {
this.executorServiceDelegate = executorService;