From f4d6ebda637cbd2742fadf6092fefeeed56e6e95 Mon Sep 17 00:00:00 2001 From: Athou Date: Sat, 18 May 2013 17:50:38 +0200 Subject: [PATCH] more metrics --- .../java/com/commafeed/backend/MetricsBean.java | 14 +++++++++++++- .../backend/services/FeedUpdateService.java | 3 ++- 2 files changed, 15 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/commafeed/backend/MetricsBean.java b/src/main/java/com/commafeed/backend/MetricsBean.java index 4afbe0c7..5f46efc4 100644 --- a/src/main/java/com/commafeed/backend/MetricsBean.java +++ b/src/main/java/com/commafeed/backend/MetricsBean.java @@ -33,12 +33,15 @@ public class MetricsBean { thisHour.feedsRefreshed++; } - public void feedUpdated(int entriesCount) { + public void feedUpdated(int entriesCount, int statusesCount) { thisHour.feedsUpdated++; thisMinute.feedsUpdated++; thisHour.entriesInserted += entriesCount; thisMinute.entriesInserted += entriesCount; + + thisHour.statusesInserted += statusesCount; + thisMinute.statusesInserted += statusesCount; } public Metric getLastMinute() { @@ -53,6 +56,7 @@ public class MetricsBean { private int feedsRefreshed; private int feedsUpdated; private int entriesInserted; + private int statusesInserted; public int getFeedsRefreshed() { return feedsRefreshed; @@ -78,5 +82,13 @@ public class MetricsBean { this.entriesInserted = entriesInserted; } + public int getStatusesInserted() { + return statusesInserted; + } + + public void setStatusesInserted(int statusesInserted) { + this.statusesInserted = statusesInserted; + } + } } diff --git a/src/main/java/com/commafeed/backend/services/FeedUpdateService.java b/src/main/java/com/commafeed/backend/services/FeedUpdateService.java index 8c73b1e5..97151ccf 100644 --- a/src/main/java/com/commafeed/backend/services/FeedUpdateService.java +++ b/src/main/java/com/commafeed/backend/services/FeedUpdateService.java @@ -95,7 +95,8 @@ public class FeedUpdateService { feedEntryDAO.saveOrUpdate(entryUpdateList); feedEntryStatusDAO.saveOrUpdate(statusUpdateList); - metricsBean.feedUpdated(entryUpdateList.size()); + metricsBean + .feedUpdated(entryUpdateList.size(), statusUpdateList.size()); } private FeedEntry findEntry(List existingEntries, FeedEntry entry) {