X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=netconf%2Fmessagebus-netconf%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fnetconf%2Fmessagebus%2Feventsources%2Fnetconf%2FNetconfTestUtils.java;h=aa908b2e09b6db280417c85be75988cb927e8f7e;hb=982e75ece2483e413befe3edd8fd90022a644f72;hp=3e04fc3a85c650ec9c4047d9ea13c5967b2edc93;hpb=07332923b85725c03472c49a4a2b4e6ee98b74fa;p=netconf.git diff --git a/netconf/messagebus-netconf/src/test/java/org/opendaylight/netconf/messagebus/eventsources/netconf/NetconfTestUtils.java b/netconf/messagebus-netconf/src/test/java/org/opendaylight/netconf/messagebus/eventsources/netconf/NetconfTestUtils.java index 3e04fc3a85..aa908b2e09 100644 --- a/netconf/messagebus-netconf/src/test/java/org/opendaylight/netconf/messagebus/eventsources/netconf/NetconfTestUtils.java +++ b/netconf/messagebus-netconf/src/test/java/org/opendaylight/netconf/messagebus/eventsources/netconf/NetconfTestUtils.java @@ -17,13 +17,15 @@ import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.netmod.notification.r import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.netmod.notification.rev080714.netconf.StreamsBuilder; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.netmod.notification.rev080714.netconf.streams.Stream; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.netmod.notification.rev080714.netconf.streams.StreamBuilder; -import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.DomainName; -import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Host; +import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.DomainName; +import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Host; import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.NetconfNode; import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.NetconfNodeBuilder; import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.NetconfNodeConnectionStatus.ConnectionStatus; import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.netconf.node.connection.status.AvailableCapabilities; import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.netconf.node.connection.status.AvailableCapabilitiesBuilder; +import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.netconf.node.connection.status.available.capabilities.AvailableCapability; +import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.netconf.node.connection.status.available.capabilities.AvailableCapabilityBuilder; import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.network.topology.topology.topology.types.TopologyNetconf; import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology; import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId; @@ -44,61 +46,63 @@ import org.opendaylight.yangtools.yang.data.impl.schema.builder.api.CollectionNo public final class NetconfTestUtils { - public static final String notification_capability_prefix = "(urn:ietf:params:xml:ns:netconf:notification"; + public static final String NOTIFICATION_CAPABILITY_PREFIX = "(urn:ietf:params:xml:ns:netconf:notification"; private NetconfTestUtils() { } - public static Node getNetconfNode(String nodeIdent, String hostName, ConnectionStatus cs, - String notificationCapabilityPrefix) { + public static Node getNetconfNode(final String nodeIdent, final String hostName, final ConnectionStatus cs, + final String notificationCapabilityPrefix) { DomainName dn = new DomainName(hostName); Host host = new Host(dn); - List avCapList = new ArrayList<>(); - avCapList.add(notificationCapabilityPrefix + "_availableCapabilityString1"); + List avCapList = new ArrayList<>(); + avCapList.add(new AvailableCapabilityBuilder().setCapability(notificationCapabilityPrefix + + "_availableCapabilityString1").build()); AvailableCapabilities avCaps = new AvailableCapabilitiesBuilder().setAvailableCapability(avCapList).build(); NetconfNode nn = new NetconfNodeBuilder().setConnectionStatus(cs).setHost(host).setAvailableCapabilities(avCaps) - .build(); + .build(); NodeId nodeId = new NodeId(nodeIdent); NodeKey nk = new NodeKey(nodeId); NodeBuilder nb = new NodeBuilder(); - nb.setKey(nk); + nb.withKey(nk); nb.addAugmentation(NetconfNode.class, nn); return nb.build(); } - public static Node getNode(String nodeIdent) { + public static Node getNode(final String nodeIdent) { NodeId nodeId = new NodeId(nodeIdent); NodeKey nk = new NodeKey(nodeId); NodeBuilder nb = new NodeBuilder(); - nb.setKey(nk); + nb.withKey(nk); return nb.build(); } - public static InstanceIdentifier getInstanceIdentifier(Node node) { - TopologyKey NETCONF_TOPOLOGY_KEY = new TopologyKey(new TopologyId(TopologyNetconf.QNAME.getLocalName())); + public static InstanceIdentifier getInstanceIdentifier(final Node node) { + TopologyKey netconfTopologyKey = new TopologyKey(new TopologyId(TopologyNetconf.QNAME.getLocalName())); InstanceIdentifier nodeII = InstanceIdentifier.create(NetworkTopology.class) - .child(Topology.class, NETCONF_TOPOLOGY_KEY).child(Node.class, node.getKey()); + .child(Topology.class, netconfTopologyKey).child(Node.class, node.key()); return nodeII; } - public static Optional getAvailableStream(String Name, boolean replaySupport) { - Stream stream = new StreamBuilder().setName(new StreamNameType(Name)).setReplaySupport(replaySupport).build(); + public static Optional getAvailableStream(final String name, final boolean replaySupport) { + Stream stream = new StreamBuilder().setName(new StreamNameType(name)).setReplaySupport(replaySupport).build(); List streamList = new ArrayList<>(); streamList.add(stream); Streams streams = new StreamsBuilder().setStream(streamList).build(); return Optional.of(streams); } - public static NormalizedNode getStreamsNode(String... streamName) { + public static NormalizedNode getStreamsNode(final String... streamName) { QName nameNode = QName.create(Stream.QNAME, "name"); Set streamSet = new HashSet<>(); for (String s : streamName) { MapEntryNode stream = Builders.mapEntryBuilder() - .withNodeIdentifier(new YangInstanceIdentifier.NodeIdentifierWithPredicates(Stream.QNAME, nameNode, s)) + .withNodeIdentifier(new YangInstanceIdentifier + .NodeIdentifierWithPredicates(Stream.QNAME, nameNode, s)) .withChild(Builders.leafBuilder() .withNodeIdentifier(new YangInstanceIdentifier.NodeIdentifier(nameNode)) .withValue(s) @@ -107,7 +111,8 @@ public final class NetconfTestUtils { streamSet.add(stream); } - CollectionNodeBuilder streams = Builders.mapBuilder().withNodeIdentifier(YangInstanceIdentifier.NodeIdentifier.create(Stream.QNAME)); + CollectionNodeBuilder streams = + Builders.mapBuilder().withNodeIdentifier(YangInstanceIdentifier.NodeIdentifier.create(Stream.QNAME)); for (MapEntryNode mapEntryNode : streamSet) { streams.withChild(mapEntryNode); }