@Test public void testRegister() throws Exception { DataBroker dataBroker = mock(DataBroker.class); identityListener.register(dataBroker, LogicalDatastoreType.CONFIGURATION); verify(dataBroker).registerDataTreeChangeListener(any(DataTreeIdentifier.class), eq(identityListener)); }
public ListenerRegistration<DataTreeChangeListener> register(final DataBroker dataBroker, final LogicalDatastoreType datastoreType) { return dataBroker.registerDataTreeChangeListener(DataTreeIdentifier.create(datastoreType, SUBSCRIBED_PATH.child(Node.class).augmentation(SxpNodeIdentity.class)), this); }
NodeIdentityListener implements ClusteredDataTreeChangeListener<SxpNodeIdentity> { public ListenerRegistration<DataTreeChangeListener> register(final DataBroker dataBroker, final LogicalDatastoreType datastoreType) { return dataBroker.registerDataTreeChangeListener(DataTreeIdentifier.create(datastoreType, SUBSCRIBED_PATH.child(Node.class).augmentation(SxpNodeIdentity.class)), this); } }
NodeIdentityListener implements ClusteredDataTreeChangeListener<SxpNodeIdentity> { public ListenerRegistration<DataTreeChangeListener> register(final DataBroker dataBroker, final LogicalDatastoreType datastoreType) { return dataBroker.registerDataTreeChangeListener(DataTreeIdentifier.create(datastoreType, SUBSCRIBED_PATH.child(Node.class).augmentation(SxpNodeIdentity.class)), this); } NodeIdentityListener(DatastoreAccess datastoreAccess); }
NodeIdentityListener implements ClusteredDataTreeChangeListener<SxpNodeIdentity> { public ListenerRegistration<DataTreeChangeListener> register(final DataBroker dataBroker, final LogicalDatastoreType datastoreType) { return dataBroker.registerDataTreeChangeListener(DataTreeIdentifier.create(datastoreType, SUBSCRIBED_PATH.child(Node.class).augmentation(SxpNodeIdentity.class)), this); } NodeIdentityListener(DatastoreAccess datastoreAccess); void addSubListener(Listener<SxpNodeIdentity, ?> listener); ListenerRegistration<DataTreeChangeListener> register(final DataBroker dataBroker,
            final LogicalDatastoreType datastoreType); @Override synchronized void onDataTreeChanged(@Nonnull Collection<DataTreeModification<SxpNodeIdentity>> changes); }
NodeIdentityListener implements ClusteredDataTreeChangeListener<SxpNodeIdentity> { public ListenerRegistration<DataTreeChangeListener> register(final DataBroker dataBroker, final LogicalDatastoreType datastoreType) { return dataBroker.registerDataTreeChangeListener(DataTreeIdentifier.create(datastoreType, SUBSCRIBED_PATH.child(Node.class).augmentation(SxpNodeIdentity.class)), this); } NodeIdentityListener(DatastoreAccess datastoreAccess); void addSubListener(Listener<SxpNodeIdentity, ?> listener); ListenerRegistration<DataTreeChangeListener> register(final DataBroker dataBroker,
            final LogicalDatastoreType datastoreType); @Override synchronized void onDataTreeChanged(@Nonnull Collection<DataTreeModification<SxpNodeIdentity>> changes); static final InstanceIdentifier<Topology> SUBSCRIBED_PATH; }