- InMemoryDOMStoreTreeChangePublisher(final ExecutorService listenerExecutor, final int maxQueueSize) {
- notificationManager = QueuedNotificationManager.create(listenerExecutor, (listener, notifications) -> {
- if (!listener.isClosed()) {
- listener.getInstance().onDataTreeChanged(notifications);
- }
- }, maxQueueSize, "DataTreeChangeListenerQueueMgr");
+ InMemoryDOMStoreTreeChangePublisher(final String dsName, final ExecutorService listenerExecutor,
+ final int maxQueueSize) {
+ notificationManager = new EqualityQueuedNotificationManager<>("DataTreeChangeListenerQueueMgr + dsName",
+ listenerExecutor, maxQueueSize,
+ (listener, notifications) -> {
+ if (!listener.isClosed()) {
+ listener.getInstance().onDataTreeChanged(notifications);
+ }
+ });