@Test public void testProcessUpdatedNeutronDto() throws Exception { putPortAndBaseEndpointByPort(); Port updatedPort = new PortBuilder(port).setName("renamed").build(); WriteTransaction wTx = dataBroker.newWriteOnlyTransaction(); wTx.put(LogicalDatastoreType.CONFIGURATION, TestUtils.createPortIid(updatedPort.getKey()), updatedPort); wTx.submit().get(); neutronListener.close(); verify(baseEpByPortListener).processUpdatedNeutronDto(port, updatedPort); }
@Override public void close() { registeredListener.close(); }
NeutronListener implements ClusteredDataTreeChangeListener<Neutron>, Closeable { @Override public void close() { registeredListener.close(); } }
NeutronListener implements ClusteredDataTreeChangeListener<Neutron>, Closeable { @Override public void close() { registeredListener.close(); } NeutronListener(DataBroker dataBroker, NodeId routingNode); }
NeutronListener implements ClusteredDataTreeChangeListener<Neutron>, Closeable { @Override public void close() { registeredListener.close(); } NeutronListener(DataBroker dataBroker, NodeId routingNode); @Override void onDataTreeChanged(Collection<DataTreeModification<Neutron>> changes); @Override void close(); }
NeutronListener implements ClusteredDataTreeChangeListener<Neutron>, Closeable { @Override public void close() { registeredListener.close(); } NeutronListener(DataBroker dataBroker, NodeId routingNode); @Override void onDataTreeChanged(Collection<DataTreeModification<Neutron>> changes); @Override void close();  }