+ listeners.streamListeners().forEach(listener -> {
+ try {
+ listener.onMountPointCreated(mountPointId);
+ } catch (final Exception ex) {
+ LOG.error("Listener {} failed on mount point {} created event", listener, mountPoint, ex);
+ }
+ });
+
+ return new AbstractObjectRegistration<>(mountPoint) {
+ @Override
+ protected void removeRegistration() {
+ unregisterMountPoint(getInstance().getIdentifier());
+ }
+ };