CAMEL-6436: Fixed rss feed to include feeds with same pubtimestamp.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/2c9ff017 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/2c9ff017 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/2c9ff017 Branch: refs/heads/master Commit: 2c9ff0172980aea8a359d78f1190b33317dd3d8e Parents: c6620db Author: Claus Ibsen <davscl...@apache.org> Authored: Tue Jul 30 12:20:23 2013 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Tue Jul 30 16:28:00 2013 +0200 ---------------------------------------------------------------------- .../java/org/apache/camel/component/atom/UpdatedDateFilter.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/2c9ff017/components/camel-atom/src/main/java/org/apache/camel/component/atom/UpdatedDateFilter.java ---------------------------------------------------------------------- diff --git a/components/camel-atom/src/main/java/org/apache/camel/component/atom/UpdatedDateFilter.java b/components/camel-atom/src/main/java/org/apache/camel/component/atom/UpdatedDateFilter.java index 2d5fbb9..547b5ff 100644 --- a/components/camel-atom/src/main/java/org/apache/camel/component/atom/UpdatedDateFilter.java +++ b/components/camel-atom/src/main/java/org/apache/camel/component/atom/UpdatedDateFilter.java @@ -41,7 +41,8 @@ public class UpdatedDateFilter implements EntryFilter { public boolean isValidEntry(FeedEndpoint endpoint, Object feed, Object entry) { Date updated = ((Entry)entry).getUpdated(); - if (updated == null) { // never been updated so get published date + if (updated == null) { + // never been updated so get published date updated = ((Entry)entry).getPublished(); } if (updated == null) { @@ -49,7 +50,7 @@ public class UpdatedDateFilter implements EntryFilter { return true; } if (lastUpdate != null) { - if (lastUpdate.after(updated) || lastUpdate.equals(updated)) { + if (lastUpdate.after(updated)) { LOG.debug("Entry is older than lastupdate=[{}], no valid entry=[{}]", lastUpdate, entry); return false; }
