commit 92c64ebea240019a01fd19e84aa6c5cd37c63d06
author Madan Jampani <madan@onlab.us> Thu Jul 23 15:37:07 2015 -0700
committer Gerrit Code Review <gerrit@onlab.us> Thu Jul 23 23:17:58 2015 +0000
tree 94a43c15d5ddc1cec1faf791acf47e0799395a27
parent bd1eb3fba45b74b136e3c494de55147342896813

More Unit tests

Change-Id: I32dd3851e490979621c4a5205c6e041dee900244

core/store/dist/src/main/java/org/onosproject/store/ecmap/EventuallyConsistentMapImpl.java

diff --git a/core/store/dist/src/main/java/org/onosproject/store/ecmap/EventuallyConsistentMapImpl.java b/core/store/dist/src/main/java/org/onosproject/store/ecmap/EventuallyConsistentMapImpl.java
index 2de8947..b56d74b 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/ecmap/EventuallyConsistentMapImpl.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/ecmap/EventuallyConsistentMapImpl.java
@@ -653,7 +653,7 @@
         public void processItems(List<UpdateEntry<K, V>> items) {
             Map<K, UpdateEntry<K, V>> map = Maps.newHashMap();
             items.forEach(item -> map.compute(item.key(), (key, existing) ->
-                    existing == null || item.compareTo(existing) > 0 ? item : existing));
+                    item.isNewerThan(existing) ? item : existing));
             communicationExecutor.submit(() -> {
                 clusterCommunicator.unicast(ImmutableList.copyOf(map.values()),
                                             updateMessageSubject,