commit a009447d795c30d1680fcafa06c54465932d1957
author Marcin Czech <maczech@gmail.com> Mon Dec 30 13:37:55 2019 +0000
committer Gerrit Code Review <noreply-gerritcodereview@google.com> Mon Dec 30 13:37:55 2019 +0000
tree 3ddd473c658d27a73ac77b8fab786e6ecab51d34
parent d0965a4bd29784e64d82e0346f39cd41c9156511
parent 5bd1d5f52bc3130e8b7643464e5fb4c9f134a8ea

Merge "Implement broker api replayAllEvents functionality" into stable-3.0

external_plugin_deps.bzl

diff --git a/external_plugin_deps.bzl b/external_plugin_deps.bzl
index b814fbc..ac48feb 100644
--- a/external_plugin_deps.bzl
+++ b/external_plugin_deps.bzl
@@ -15,6 +15,6 @@
 
     maven_jar(
         name = "events-broker",
-        artifact = "com.gerritforge:events-broker:3.0.3",
-        sha1 = "efdc5bf6897563e2f6f85bfc1b8a5d65e3393424",
+        artifact = "com.gerritforge:events-broker:3.0.4",
+        sha1 = "350b438f532678b1f9a277b7e7b6fa9da4b725b3",
     )

src/main/java/com/googlesource/gerrit/plugins/multisite/broker/BrokerApiNoOp.java

diff --git a/src/main/java/com/googlesource/gerrit/plugins/multisite/broker/BrokerApiNoOp.java b/src/main/java/com/googlesource/gerrit/plugins/multisite/broker/BrokerApiNoOp.java
index b38ac6b..314437e 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/multisite/broker/BrokerApiNoOp.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/multisite/broker/BrokerApiNoOp.java
@@ -49,4 +49,7 @@
   public Set<TopicSubscriber> topicSubscribers() {
     return topicSubscribers;
   }
+
+  @Override
+  public void replayAllEvents(String topic) {}
 }

src/main/java/com/googlesource/gerrit/plugins/multisite/broker/BrokerApiWrapper.java

diff --git a/src/main/java/com/googlesource/gerrit/plugins/multisite/broker/BrokerApiWrapper.java b/src/main/java/com/googlesource/gerrit/plugins/multisite/broker/BrokerApiWrapper.java
index b266eb0..71be5e6 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/multisite/broker/BrokerApiWrapper.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/multisite/broker/BrokerApiWrapper.java
@@ -83,4 +83,9 @@
   public Set<TopicSubscriber> topicSubscribers() {
     return apiDelegate.get().topicSubscribers();
   }
+
+  @Override
+  public void replayAllEvents(String topic) {
+    apiDelegate.get().replayAllEvents(topic);
+  }
 }