import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode;
import org.opendaylight.yangtools.yang.data.api.schema.DOMSourceAnyxmlNode;
import org.opendaylight.yangtools.yang.data.api.schema.DataContainerChild;
-import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
import org.opendaylight.yangtools.yang.data.impl.schema.Builders;
import org.opendaylight.yangtools.yang.model.api.EffectiveModelContext;
import org.opendaylight.yangtools.yang.model.api.RpcDefinition;
@Test
public void testDeadlock() throws Exception {
// when rpc is successful, but transformer fails for some reason
- final RpcTransformer<NormalizedNode, DOMRpcResult> failingTransformer = mock(RpcTransformer.class);
+ final RpcTransformer<ContainerNode, DOMRpcResult> failingTransformer = mock(RpcTransformer.class);
final RemoteDeviceCommunicator communicatorMock = mock(RemoteDeviceCommunicator.class);
final NetconfMessage msg = null;
final RpcResult<NetconfMessage> result = RpcResultBuilder.success(msg).build();
public void testInvokeRpc() throws Exception {
ContainerNode input = createNode("urn:ietf:params:xml:ns:netconf:base:1.0", "2011-06-01", "filter");
final DOMRpcResult result = rpc.invokeRpc(type, input).get();
- assertEquals(expectedReply.getResult().getIdentifier(), result.getResult().getIdentifier());
+ assertEquals(expectedReply.value().getIdentifier(), result.value().getIdentifier());
assertEquals(resolveNode(expectedReply), resolveNode(result));
}
private static Node resolveNode(final DOMRpcResult result) {
- DataContainerChild value = ((ContainerNode) result.getResult())
- .findChildByArg(NetconfMessageTransformUtil.NETCONF_DATA_NODEID).get();
+ DataContainerChild value = result.value()
+ .findChildByArg(NetconfMessageTransformUtil.NETCONF_DATA_NODEID).orElseThrow();
Node node = ((DOMSourceAnyxmlNode)value).body().getNode();
assertNotNull(node);
return node;