diff --git a/commafeed-server/src/main/java/com/commafeed/backend/feed/FeedRefreshUpdater.java b/commafeed-server/src/main/java/com/commafeed/backend/feed/FeedRefreshUpdater.java index 8f4424c7..0383c6d3 100644 --- a/commafeed-server/src/main/java/com/commafeed/backend/feed/FeedRefreshUpdater.java +++ b/commafeed-server/src/main/java/com/commafeed/backend/feed/FeedRefreshUpdater.java @@ -171,8 +171,6 @@ public class FeedRefreshUpdater { List users = subscriptions.stream().map(FeedSubscription::getUser).toList(); cache.invalidateUnreadCount(subscriptions.toArray(new FeedSubscription[0])); cache.invalidateUserRootCategory(users.toArray(new User[0])); - - notifyOverWebsocket(unreadCountBySubscription); } } @@ -187,6 +185,8 @@ public class FeedRefreshUpdater { unitOfWork.run(() -> feedService.save(feed)); + notifyOverWebsocket(unreadCountBySubscription); + return processed; }