@Test public void testSetNodeIdRemote() throws Exception { NodeId nodeId = new NodeId("1.1.1.1"); ArgumentCaptor<Connection> captor = ArgumentCaptor.forClass(Connection.class); connection.setNodeIdRemote(nodeId); assertEquals(nodeId, connection.getNodeIdRemote()); verify(writeTransaction, atLeastOnce()).merge(any(LogicalDatastoreType.class), any(InstanceIdentifier.class), captor.capture()); assertEquals(nodeId, captor.getValue().getNodeId()); }
@Override public void setNodeIdRemote(NodeId remoteNodeId) { super.setNodeIdRemote(remoteNodeId); if (datastoreAccess != null) { datastoreAccess.checkAndMerge(getIdentifier(), new ConnectionBuilder().setPeerAddress(address).setTcpPort(port).setNodeId(remoteNodeId).build(), LogicalDatastoreType.OPERATIONAL, true); } }
SxpDatastoreConnection extends org.opendaylight.sxp.core.SxpConnection { @Override public void setNodeIdRemote(NodeId remoteNodeId) { super.setNodeIdRemote(remoteNodeId); if (datastoreAccess != null) { datastoreAccess.checkAndMerge(getIdentifier(), new ConnectionBuilder().setPeerAddress(address).setTcpPort(port).setNodeId(remoteNodeId).build(), LogicalDatastoreType.OPERATIONAL, true); } } }
SxpDatastoreConnection extends org.opendaylight.sxp.core.SxpConnection { @Override public void setNodeIdRemote(NodeId remoteNodeId) { super.setNodeIdRemote(remoteNodeId); if (datastoreAccess != null) { datastoreAccess.checkAndMerge(getIdentifier(), new ConnectionBuilder().setPeerAddress(address).setTcpPort(port).setNodeId(remoteNodeId).build(), LogicalDatastoreType.OPERATIONAL, true); } } private  SxpDatastoreConnection(DatastoreAccess datastoreAccess, SxpNode owner, Connection connection, String domain); }
SxpDatastoreConnection extends org.opendaylight.sxp.core.SxpConnection { @Override public void setNodeIdRemote(NodeId remoteNodeId) { super.setNodeIdRemote(remoteNodeId); if (datastoreAccess != null) { datastoreAccess.checkAndMerge(getIdentifier(), new ConnectionBuilder().setPeerAddress(address).setTcpPort(port).setNodeId(remoteNodeId).build(), LogicalDatastoreType.OPERATIONAL, true); } } private  SxpDatastoreConnection(DatastoreAccess datastoreAccess, SxpNode owner, Connection connection, String domain); static SxpDatastoreConnection create(DatastoreAccess datastoreAccess, SxpNode owner, Connection connection,
            String domain); @Override void setNodeIdRemote(NodeId remoteNodeId); @Override void setUpdateOrKeepaliveMessageTimestamp(); @Override void shutdown(); }
SxpDatastoreConnection extends org.opendaylight.sxp.core.SxpConnection { @Override public void setNodeIdRemote(NodeId remoteNodeId) { super.setNodeIdRemote(remoteNodeId); if (datastoreAccess != null) { datastoreAccess.checkAndMerge(getIdentifier(), new ConnectionBuilder().setPeerAddress(address).setTcpPort(port).setNodeId(remoteNodeId).build(), LogicalDatastoreType.OPERATIONAL, true); } } private  SxpDatastoreConnection(DatastoreAccess datastoreAccess, SxpNode owner, Connection connection, String domain); static SxpDatastoreConnection create(DatastoreAccess datastoreAccess, SxpNode owner, Connection connection,
            String domain); @Override void setNodeIdRemote(NodeId remoteNodeId); @Override void setUpdateOrKeepaliveMessageTimestamp(); @Override void shutdown();  }