*/
package org.opendaylight.netconf.nettyutil;
-import com.google.common.base.Preconditions;
+import static java.util.Objects.requireNonNull;
+
+import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
final Bootstrap bootstrap, final AbstractNetconfDispatcher.PipelineInitializer<S> initializer) {
super(executor);
this.bootstrap = bootstrap;
- this.initializer = Preconditions.checkNotNull(initializer);
- this.dispatcher = Preconditions.checkNotNull(dispatcher);
- this.address = Preconditions.checkNotNull(address);
- this.strategyFactory = Preconditions.checkNotNull(connectStrategyFactory);
+ this.initializer = requireNonNull(initializer);
+ this.dispatcher = requireNonNull(dispatcher);
+ this.address = requireNonNull(address);
+ this.strategyFactory = requireNonNull(connectStrategyFactory);
}
synchronized void connect() {
* @return true if initial connection was established successfully, false if initial connection failed due to e.g.
* Connection refused, Negotiation failed
*/
+ @SuppressFBWarnings(value = "UPM_UNCALLED_PRIVATE_METHOD",
+ justification = "https://github.com/spotbugs/spotbugs/issues/811")
private synchronized boolean isInitialConnectFinished() {
- Preconditions.checkNotNull(pending);
+ requireNonNull(pending);
return pending.isDone() && pending.isSuccess();
}
@Override
public synchronized boolean cancel(final boolean mayInterruptIfRunning) {
if (super.cancel(mayInterruptIfRunning)) {
- Preconditions.checkNotNull(pending);
+ requireNonNull(pending);
this.pending.cancel(mayInterruptIfRunning);
return true;
}