Build compatibility with events-broker 3.10 events-broker 3.10 introduced a new TopicSubscriberWithGroupId API. Add method stubs for the new API. Bug: Issue 307031744 Change-Id: I534a062fbd75b474de1dc2b59bdfe347fe460571
diff --git a/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/RabbitMqBrokerApi.java b/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/RabbitMqBrokerApi.java index 3601bd0..40a378e 100644 --- a/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/RabbitMqBrokerApi.java +++ b/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/RabbitMqBrokerApi.java
@@ -16,6 +16,7 @@ import com.gerritforge.gerrit.eventbroker.BrokerApi; import com.gerritforge.gerrit.eventbroker.TopicSubscriber; +import com.gerritforge.gerrit.eventbroker.TopicSubscriberWithGroupId; import com.google.common.collect.ImmutableSet; import com.google.common.flogger.FluentLogger; import com.google.common.util.concurrent.ListenableFuture; @@ -75,4 +76,22 @@ throw new NotImplementedException( "The RabbitMqBrokerApi does not support replayAllEvents yet."); } + + @Override + public void disconnect(String topic, String groupId) { + throw new NotImplementedException( + "The RabbitMqBrokerApi does not support TopicSubscribers with group ID yet."); + } + + @Override + public void receiveAsync(String topic, String groupId, Consumer<Event> consumer) { + throw new NotImplementedException( + "The RabbitMqBrokerApi does not support TopicSubscribers with group ID yet."); + } + + @Override + public Set<TopicSubscriberWithGroupId> topicSubscribersWithGroupId() { + throw new NotImplementedException( + "The RabbitMqBrokerApi does not support TopicSubscribers with group ID yet."); + } }