X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fclustering%2Fintegrationtest%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fclustering%2Fservices_implementation%2Finternal%2FClusteringServicesIT.java;fp=opendaylight%2Fclustering%2Fintegrationtest%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fclustering%2Fservices_implementation%2Finternal%2FClusteringServicesIT.java;h=e40454dea2259c085e07fe3db3e9800dfef1209a;hb=0cb78c0a7b96fe83eebb774896499ecf94eeba61;hp=80f5558bcf853d91e03cf35ed95ceac3bb1419b0;hpb=91e19b8e94b926a286d1ad4cd1077858017931e9;p=controller.git

diff --git a/opendaylight/clustering/integrationtest/src/test/java/org/opendaylight/controller/clustering/services_implementation/internal/ClusteringServicesIT.java b/opendaylight/clustering/integrationtest/src/test/java/org/opendaylight/controller/clustering/services_implementation/internal/ClusteringServicesIT.java
index 80f5558bcf..e40454dea2 100644
--- a/opendaylight/clustering/integrationtest/src/test/java/org/opendaylight/controller/clustering/services_implementation/internal/ClusteringServicesIT.java
+++ b/opendaylight/clustering/integrationtest/src/test/java/org/opendaylight/controller/clustering/services_implementation/internal/ClusteringServicesIT.java
@@ -362,6 +362,25 @@ public class ClusteringServicesIT {
             assertTrue(up.value.equals("baz"));
             assertTrue(up.cacheName.equals(cache1));
 
+            /**********************************/
+            /* RE-UPDATE AN EXISTING KEY CASE */
+            /**********************************/
+            // Start monitoring the updates
+            res = listener.restart(1);
+            // modify the cache
+            cm11.put(k1, "baz");
+            // Wait
+            res.await(100L, TimeUnit.SECONDS);
+            // Analyze the updates
+            ups = listener.getUpdates();
+            assertTrue(ups.size() == 1);
+            // Validate we get an update with expect fields
+            up = ups.get(0);
+            assertTrue(up.t.equals(UpdateType.CHANGED));
+            assertTrue(up.key.equals(k1));
+            assertTrue(up.value.equals("baz"));
+            assertTrue(up.cacheName.equals(cache1));
+
             /********************************/
             /* REMOVAL OF EXISTING KEY CASE */
             /********************************/