commit 3fc451324674d61bc98b4fca2435cd5e36ae627a
author Luca Milanesio <luca.milanesio@gmail.com> Tue Feb 26 17:00:04 2019 +0000
committer Luca Milanesio <luca.milanesio@gmail.com> Tue Feb 26 17:01:11 2019 +0000
tree 81acbffb231a7d22e96fc238b1c410cc23a186a6
parent c11368628a6928cdd92a1fcd436284fe37d4f7b4

EventConsumerIT: createChange should create patchset-created

Remove residual flaky-ness by consuming the patchset-created
event produced in the test.

Change-Id: Ic257f71c6c1c832dedbe494792507f1f79c21196

src/test/java/com/googlesource/gerrit/plugins/multisite/kafka/consumer/EventConsumerIT.java

diff --git a/src/test/java/com/googlesource/gerrit/plugins/multisite/kafka/consumer/EventConsumerIT.java b/src/test/java/com/googlesource/gerrit/plugins/multisite/kafka/consumer/EventConsumerIT.java
index 993c138..ea00251 100644
--- a/src/test/java/com/googlesource/gerrit/plugins/multisite/kafka/consumer/EventConsumerIT.java
+++ b/src/test/java/com/googlesource/gerrit/plugins/multisite/kafka/consumer/EventConsumerIT.java
@@ -89,11 +89,12 @@
     drainQueue(droppedEventsQueue);
 
     createChange();
-    List<String> createdChangeEvents = receiveFromQueue(droppedEventsQueue, 2);
-    assertThat(createdChangeEvents).hasSize(2);
+    List<String> createdChangeEvents = receiveFromQueue(droppedEventsQueue, 3);
+    assertThat(createdChangeEvents).hasSize(3);
 
     assertThat(createdChangeEvents).contains("change-index");
     assertThat(createdChangeEvents).contains("ref-updated");
+    assertThat(createdChangeEvents).contains("patchset-created");
   }
 
   @Test