import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;
import java.util.function.Supplier;
-import javax.annotation.Nonnull;
-import javax.annotation.Nullable;
+import org.eclipse.jdt.annotation.NonNull;
import org.opendaylight.openflowplugin.api.ConnectionException;
public class StatisticsPollingService extends AbstractScheduledService {
private final Supplier<ListenableFuture<Boolean>> gatheringSupplier;
private final SettableFuture<Void> future = SettableFuture.create();
- StatisticsPollingService(@Nonnull final TimeCounter counter,
+ StatisticsPollingService(@NonNull final TimeCounter counter,
final long pollingInterval,
final long maximumTimerDelay,
- @Nonnull final Supplier<ListenableFuture<Boolean>> gatheringSupplier) {
+ @NonNull final Supplier<ListenableFuture<Boolean>> gatheringSupplier) {
this.counter = counter;
this.pollingInterval = pollingInterval;
this.maximumTimerDelay = maximumTimerDelay;
}
@Override
- protected void startUp() throws Exception {
+ protected void startUp() {
counter.markStart();
}
Futures.addCallback(gatheringSupplier.get(), new FutureCallback<Boolean>() {
@Override
- public void onSuccess(@Nullable final Boolean result) {
+ public void onSuccess(final Boolean result) {
waitFuture.complete(result);
}
@Override
- public void onFailure(@Nonnull final Throwable throwable) {
+ public void onFailure(final Throwable throwable) {
waitFuture.completeExceptionally(throwable);
}
}, MoreExecutors.directExecutor());
}
}
}
-}
\ No newline at end of file
+}