Use UUID compare for more precision.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/1b1ed8b6 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/1b1ed8b6 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/1b1ed8b6 Branch: refs/heads/master Commit: 1b1ed8b63bbfd3c5fcf6f0e4a09f2009e8709d53 Parents: aea9264 Author: Michael Russo <[email protected]> Authored: Thu Nov 19 12:21:48 2015 -0800 Committer: Michael Russo <[email protected]> Committed: Thu Nov 19 12:21:48 2015 -0800 ---------------------------------------------------------------------- .../usergrid/corepersistence/asyncevents/EventBuilderImpl.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/1b1ed8b6/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/EventBuilderImpl.java ---------------------------------------------------------------------- diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/EventBuilderImpl.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/EventBuilderImpl.java index f7f7ba3..c9ae6da 100644 --- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/EventBuilderImpl.java +++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/EventBuilderImpl.java @@ -22,6 +22,7 @@ package org.apache.usergrid.corepersistence.asyncevents; import java.util.List; +import org.apache.usergrid.utils.UUIDUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -144,7 +145,7 @@ public class EventBuilderImpl implements EventBuilder { ecmDeleteObservable = ecm.getVersions( entityId ) - .filter( mvccLogEntry-> mvccLogEntry.getVersion().timestamp() <= mostRecentlyMarked.getVersion().timestamp()) + .filter( mvccLogEntry-> UUIDUtils.compare(mvccLogEntry.getVersion(), mostRecentlyMarked.getVersion()) < 0) .buffer( serializationFig.getBufferSize() ) .doOnNext( buffer -> ecm.delete( buffer ) );
