import java.util.concurrent.TimeUnit;
import org.opendaylight.controller.sal.binding.api.NotificationProviderService;
-import org.opendaylight.openflowplugin.openflow.md.core.session.IMessageDispatchService;
-import org.opendaylight.openflowplugin.openflow.md.core.session.SessionContext;
-import org.opendaylight.openflowplugin.openflow.md.queue.MessageSpy;
+import org.opendaylight.openflowplugin.api.openflow.md.core.session.IMessageDispatchService;
+import org.opendaylight.openflowplugin.api.openflow.md.core.session.SessionContext;
+import org.opendaylight.openflowplugin.api.openflow.statistics.MessageSpy;
import org.opendaylight.yangtools.yang.binding.DataContainer;
import com.google.common.util.concurrent.ListeningExecutorService;
this.maxTimeoutUnit = maxTimeoutUnit;
}
/**
- * @param rpcPool
+ * @param rpcPool executor service pool for rpc
*/
public void setRpcPool(ListeningExecutorService rpcPool) {
this.rpcPool = rpcPool;
}
/**
- * @param messageSpy
+ * @param messageSpy the message spy
*/
public void setMessageSpy(MessageSpy<DataContainer> messageSpy) {
this.messageSpy = messageSpy;