commit 147c7e1a3be0ab32da239c9fc00a6b5e4bb2c96d
author Luca Milanesio <luca.milanesio@gmail.com> Sat Dec 30 00:08:51 2023 +0000
committer Gerrit Code Review <noreply-gerritcodereview@google.com> Sat Dec 30 00:08:51 2023 +0000
tree deff19976237fd62f20d5d11d207bd2fc9446f71
parent 5558ff466107342d4c3a73425a340eb67d8f6a84
parent 5724e4bc1bed0cfd0479582897e5b8e9d5f7f025

Merge "Notify listeners when a new project is created via replication"

src/main/java/com/googlesource/gerrit/plugins/replication/pull/ReplicationQueue.java

diff --git a/src/main/java/com/googlesource/gerrit/plugins/replication/pull/ReplicationQueue.java b/src/main/java/com/googlesource/gerrit/plugins/replication/pull/ReplicationQueue.java
index 8fb6b0d..ac17fac 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/replication/pull/ReplicationQueue.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/replication/pull/ReplicationQueue.java
@@ -764,7 +764,7 @@
   private void fireBeforeStartupEvents() {
     Set<String> eventsReplayed = new HashSet<>();
     ReferenceBatchUpdatedEvent event;
-    while ((event = beforeStartupEventsQueue.poll()) != null) {
+    while ((event = beforeStartupEventsQueue.peek()) != null) {
       String eventKey =
           String.format(
               "%s:%s",
@@ -777,6 +777,7 @@
         fire(event);
         eventsReplayed.add(eventKey);
       }
+      beforeStartupEventsQueue.remove(event);
     }
   }