* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-
package ntfbenchmark.impl;
-import com.google.common.base.Throwables;
import com.google.common.util.concurrent.ListenableFuture;
import com.google.common.util.concurrent.SettableFuture;
import java.util.concurrent.ExecutionException;
-import org.opendaylight.controller.md.sal.binding.api.NotificationPublishService;
+import org.opendaylight.mdsal.binding.api.NotificationPublishService;
public class NtfbenchNonblockingProducer extends AbstractNtfbenchProducer {
@Override
+ @SuppressWarnings("checkstyle:illegalCatch")
public void run() {
int ntfOk = 0;
int ntfError = 0;
try {
lastOkFuture.get();
} catch (InterruptedException | ExecutionException e) {
- throw Throwables.propagate(e);
+ throw new RuntimeException(e);
}
}
}