diff --git a/src/main/java/com/commafeed/backend/MetricsBean.java b/src/main/java/com/commafeed/backend/MetricsBean.java index 0eed4510..fd3035c5 100644 --- a/src/main/java/com/commafeed/backend/MetricsBean.java +++ b/src/main/java/com/commafeed/backend/MetricsBean.java @@ -55,13 +55,11 @@ public class MetricsBean { } - public void entryUpdated(int statusesCount) { + public void entryInserted() { thisHour.entriesInserted++; thisMinute.entriesInserted++; - thisHour.statusesInserted += statusesCount; - thisMinute.statusesInserted += statusesCount; } public void entryCacheHit() { @@ -107,7 +105,6 @@ public class MetricsBean { private int feedsRefreshed; private int feedsUpdated; private int entriesInserted; - private int statusesInserted; private int threadWaited; private int pushNotificationsReceived; private int pushFeedsQueued; @@ -138,14 +135,6 @@ public class MetricsBean { this.entriesInserted = entriesInserted; } - public int getStatusesInserted() { - return statusesInserted; - } - - public void setStatusesInserted(int statusesInserted) { - this.statusesInserted = statusesInserted; - } - public int getThreadWaited() { return threadWaited; } diff --git a/src/main/java/com/commafeed/backend/services/FeedUpdateService.java b/src/main/java/com/commafeed/backend/services/FeedUpdateService.java index bce11260..1c63c730 100644 --- a/src/main/java/com/commafeed/backend/services/FeedUpdateService.java +++ b/src/main/java/com/commafeed/backend/services/FeedUpdateService.java @@ -71,6 +71,7 @@ public class FeedUpdateService { users.add(user); } feedEntryDAO.saveOrUpdate(entry); + metricsBean.entryInserted(); cache.invalidateUserData(users.toArray(new User[0])); } }