import org.opendaylight.yangtools.concepts.ListenerRegistration;
import org.opendaylight.yangtools.yang.common.QName;
import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode;
-import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
return;
}
- if (result.getResult() != null) {
+ if (result.value() != null) {
reschedule();
} else {
- final var errors = result.getErrors();
+ final var errors = result.errors();
if (!errors.isEmpty()) {
LOG.warn("{}: Keepalive RPC failed with error: {}", id, errors);
reschedule();
}
@Override
- public ListenableFuture<? extends DOMRpcResult> invokeRpc(final QName type, final NormalizedNode input) {
+ public ListenableFuture<? extends DOMRpcResult> invokeRpc(final QName type, final ContainerNode input) {
// FIXME: what happens if we disable keepalive and then invokeRpc() throws?
disableKeepalive();
return scheduleTimeout(delegate.invokeRpc(type, input));