X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-netconf-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fconnect%2Fnetconf%2Futil%2FNetconfRpcFutureCallback.java;h=40ff1291aed1284f33ce3e4ab03ceeb12506c1c7;hb=412db94945c5db5d2da918f5e23bd3abcecc4d10;hp=6e1e9d764fa20db25a9ff336157ee561694f616f;hpb=307f6109c6dc28b1801375a11ab871539c51aad1;p=controller.git diff --git a/opendaylight/md-sal/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/util/NetconfRpcFutureCallback.java b/opendaylight/md-sal/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/util/NetconfRpcFutureCallback.java index 6e1e9d764f..40ff1291ae 100644 --- a/opendaylight/md-sal/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/util/NetconfRpcFutureCallback.java +++ b/opendaylight/md-sal/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/util/NetconfRpcFutureCallback.java @@ -9,18 +9,16 @@ package org.opendaylight.controller.sal.connect.netconf.util; import com.google.common.util.concurrent.FutureCallback; -import org.opendaylight.controller.sal.connect.netconf.sal.tx.WriteRunningTx; +import org.opendaylight.controller.md.sal.dom.api.DOMRpcResult; import org.opendaylight.controller.sal.connect.util.RemoteDeviceId; -import org.opendaylight.yangtools.yang.common.RpcResult; -import org.opendaylight.yangtools.yang.data.api.CompositeNode; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Simple Netconf rpc logging callback */ -public class NetconfRpcFutureCallback implements FutureCallback> { - private static final Logger LOG = LoggerFactory.getLogger(WriteRunningTx.class); +public class NetconfRpcFutureCallback implements FutureCallback { + private static final Logger LOG = LoggerFactory.getLogger(NetconfRpcFutureCallback.class); private final String type; private final RemoteDeviceId id; @@ -31,15 +29,15 @@ public class NetconfRpcFutureCallback implements FutureCallback result) { - if(result.isSuccessful()) { + public void onSuccess(final DOMRpcResult result) { + if(result.getErrors().isEmpty()) { LOG.trace("{}: " + type + " invoked successfully", id); } else { onUnsuccess(result); } } - protected void onUnsuccess(final RpcResult result) { + protected void onUnsuccess(final DOMRpcResult result) { LOG.warn("{}: " + type + " invoked unsuccessfully: {}", id, result.getErrors()); }