Merge "Fix pull-replication plugin startup which was always failing" into stable-3.4
diff --git a/src/main/java/com/googlesource/gerrit/plugins/replication/pull/event/EventsBrokerMessageConsumer.java b/src/main/java/com/googlesource/gerrit/plugins/replication/pull/event/EventsBrokerMessageConsumer.java
index 13b038e..a21a48c 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/replication/pull/event/EventsBrokerMessageConsumer.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/replication/pull/event/EventsBrokerMessageConsumer.java
@@ -34,7 +34,7 @@
public class EventsBrokerMessageConsumer implements Consumer<Event>, LifecycleListener {
private static final FluentLogger logger = FluentLogger.forEnclosingClass();
- private final DynamicItem<BrokerApi> eventsBroker;
+ private final DynamicItem<BrokerApi> eventsBrokerDi;
private final StreamEventListener eventListener;
private final ShutdownState shutdownState;
private final String eventsTopicName;
@@ -48,7 +48,7 @@
@Named(STREAM_EVENTS_TOPIC_NAME) String eventsTopicName,
@Nullable @Named(STREAM_EVENTS_GROUP_ID) String groupId) {
- this.eventsBroker = eventsBroker;
+ this.eventsBrokerDi = eventsBroker;
this.eventListener = eventListener;
this.shutdownState = shutdownState;
this.eventsTopicName = eventsTopicName;
@@ -67,18 +67,18 @@
@Override
public void start() {
- BrokerApi brokerApi = eventsBroker.get();
+ BrokerApi brokerApi = eventsBrokerDi.get();
if (groupId == null) {
brokerApi.receiveAsync(eventsTopicName, this);
return;
}
- if (!(eventsBroker instanceof ExtendedBrokerApi)) {
+ if (!(brokerApi instanceof ExtendedBrokerApi)) {
throw new IllegalArgumentException(
String.format(
"Failed to load the pull-replication plugin: %s does not support the custom group-id '%s'.\n"
+ "Remove replication.eventBrokerGroupId from replication.config or install a different event-broker plugin.",
- eventsBroker.getClass(), groupId));
+ brokerApi.getClass(), groupId));
}
((ExtendedBrokerApi) brokerApi).receiveAsync(eventsTopicName, groupId, this);
@@ -87,6 +87,6 @@
@Override
public void stop() {
shutdownState.setIsShuttingDown(true);
- eventsBroker.get().disconnect();
+ eventsBrokerDi.get().disconnect();
}
}
