diff --git a/src/main/java/org/springframework/data/neo4j/core/transaction/ReactiveDefaultBookmarkManager.java b/src/main/java/org/springframework/data/neo4j/core/transaction/ReactiveDefaultBookmarkManager.java index 7f6f732f8..de16fbfb6 100644 --- a/src/main/java/org/springframework/data/neo4j/core/transaction/ReactiveDefaultBookmarkManager.java +++ b/src/main/java/org/springframework/data/neo4j/core/transaction/ReactiveDefaultBookmarkManager.java @@ -60,9 +60,9 @@ final class ReactiveDefaultBookmarkManager extends AbstractBookmarkManager { synchronized (this.bookmarks) { usedBookmarks.stream().filter(Objects::nonNull).forEach(bookmarks::remove); newBookmarks.stream().filter(Objects::nonNull).forEach(bookmarks::add); - } - if (applicationEventPublisher != null) { - applicationEventPublisher.publishEvent(new Neo4jBookmarksUpdatedEvent(new HashSet<>(bookmarks))); + if (applicationEventPublisher != null) { + applicationEventPublisher.publishEvent(new Neo4jBookmarksUpdatedEvent(new HashSet<>(bookmarks))); + } } }