+
+ listener.reset(1);
+
+ writeToStore(shard.getDataStore(), TEST_PATH, ImmutableNodes.containerNode(TEST_QNAME));
+ listener.waitForChangeEvents();
+ listener.verifyNotifiedData(TEST_PATH);
+
+ listener.reset(1);
+ JavaTestKit kit = new JavaTestKit(getSystem());
+ entry.getValue().tell(CloseDataTreeChangeListenerRegistration.getInstance(), kit.getRef());
+ kit.expectMsgClass(JavaTestKit.duration("5 seconds"), CloseDataTreeChangeListenerRegistrationReply.class);
+
+ writeToStore(shard.getDataStore(), TEST_PATH, ImmutableNodes.containerNode(TEST_QNAME));
+ listener.verifyNoNotifiedData(TEST_PATH);