Use BrokerApi for sending project list updates
Leverage the new BrokerApi for sending project list updates
through a generic message broker.
Get rid of the references to the old BrokerPublisher
abstract class.
Change-Id: Ifad38de2724b234f863f91922547db6bb057ad7a
diff --git a/src/main/java/com/googlesource/gerrit/plugins/multisite/forwarder/broker/BrokerProjectListUpdateForwarder.java b/src/main/java/com/googlesource/gerrit/plugins/multisite/forwarder/broker/BrokerProjectListUpdateForwarder.java
index ee8b1ae..235806d 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/multisite/forwarder/broker/BrokerProjectListUpdateForwarder.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/multisite/forwarder/broker/BrokerProjectListUpdateForwarder.java
@@ -18,21 +18,21 @@
import com.google.inject.Inject;
import com.google.inject.Singleton;
-import com.googlesource.gerrit.plugins.multisite.broker.BrokerPublisher;
+import com.googlesource.gerrit.plugins.multisite.broker.BrokerApi;
import com.googlesource.gerrit.plugins.multisite.forwarder.ProjectListUpdateForwarder;
import com.googlesource.gerrit.plugins.multisite.forwarder.events.ProjectListUpdateEvent;
@Singleton
public class BrokerProjectListUpdateForwarder implements ProjectListUpdateForwarder {
- private final BrokerPublisher publisher;
+ private final BrokerApi broker;
@Inject
- BrokerProjectListUpdateForwarder(BrokerPublisher publisher) {
- this.publisher = publisher;
+ BrokerProjectListUpdateForwarder(BrokerApi broker) {
+ this.broker = broker;
}
@Override
public boolean updateProjectList(ProjectListUpdateEvent event) {
- return publisher.publish(PROJECT_LIST_EVENT.topic(), event);
+ return broker.send(PROJECT_LIST_EVENT.topic(), event);
}
}
