Bump MRI upstreams

[openflowplugin.git] / openflowjava / openflow-protocol-impl / src / main / java / org / opendaylight / openflowjava / protocol / impl / core / connection / AbstractRpcListener.java

diff --git a/openflowjava/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/AbstractRpcListener.java b/openflowjava/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/AbstractRpcListener.java
index 15e12f18e3aa2b42e0dc0b7fb760925e956278f0..9df2e9b10853cb07ccf0c366a15bdc9c0ed09f90 100644 (file)
--- a/openflowjava/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/AbstractRpcListener.java
+++ b/openflowjava/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/AbstractRpcListener.java
@@ -7,13 +7,16 @@
  */
 package org.opendaylight.openflowjava.protocol.impl.core.connection;
 
-import com.google.common.base.Preconditions;
+import static com.google.common.base.Preconditions.checkState;
+import static java.util.Objects.requireNonNull;
+
 import com.google.common.util.concurrent.ListenableFuture;
 import com.google.common.util.concurrent.SettableFuture;
 import io.netty.util.concurrent.Future;
 import io.netty.util.concurrent.GenericFutureListener;
+import org.opendaylight.yangtools.yang.common.ErrorTag;
+import org.opendaylight.yangtools.yang.common.ErrorType;
 import org.opendaylight.yangtools.yang.common.RpcError;
-import org.opendaylight.yangtools.yang.common.RpcError.ErrorType;
 import org.opendaylight.yangtools.yang.common.RpcResult;
 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
 import org.slf4j.Logger;
@@ -28,7 +31,7 @@ abstract class AbstractRpcListener<T> implements GenericFutureListener<Future<Vo
         ChannelOutboundQueue.MessageHolder<Object> {
     private static final Logger LOG = LoggerFactory.getLogger(AbstractRpcListener.class);
     private static final String APPLICATION_TAG = "OPENFLOW_LIBRARY";
-    private static final String TAG = "OPENFLOW";
+    private static final ErrorTag TAG = new ErrorTag("OPENFLOW");
     private final SettableFuture<RpcResult<T>> result = SettableFuture.create();
     private final String failureInfo;
     private Object message;
@@ -37,7 +40,6 @@ abstract class AbstractRpcListener<T> implements GenericFutureListener<Future<Vo
      * Create RcpError object.
      *
      * @param info error info
-     * @param severity - error severity
      * @param message error message
      * @param cause - details of reason
      * @return RpcError
@@ -47,8 +49,8 @@ abstract class AbstractRpcListener<T> implements GenericFutureListener<Future<Vo
     }
 
     AbstractRpcListener(final Object message, final String failureInfo) {
-        this.failureInfo = Preconditions.checkNotNull(failureInfo);
-        this.message = Preconditions.checkNotNull(message);
+        this.failureInfo = requireNonNull(failureInfo);
+        this.message = requireNonNull(message);
     }
 
     public final ListenableFuture<RpcResult<T>> getResult() {
@@ -69,7 +71,7 @@ abstract class AbstractRpcListener<T> implements GenericFutureListener<Future<Vo
     @Override
     public final Object takeMessage() {
         final Object ret = message;
-        Preconditions.checkState(ret != null, "Message has already been taken");
+        checkState(ret != null, "Message has already been taken");
         message = null;
         return ret;
     }