Merge branch 'stable-3.10'
* stable-3.10:
RabbitMqBrokerApi.java: Removed unused logger
Build compatibility with events-broker 3.10
Change-Id: Ic5d9a1cbbddf005434c3887f2a4f80dd249f5487
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..879b9b6 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/RabbitMqBrokerApi.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/RabbitMqBrokerApi.java
@@ -16,8 +16,8 @@
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;
import com.google.gerrit.server.events.Event;
import com.google.inject.Inject;
@@ -30,8 +30,6 @@
import org.apache.commons.lang3.NotImplementedException;
public class RabbitMqBrokerApi implements BrokerApi {
- private static final FluentLogger logger = FluentLogger.forEnclosingClass();
-
private final BrokerApiPublisher publisher;
private final BrokerApiSubscribers subscribers;
private final Set<TopicSubscriber> topicSubscribers;
@@ -75,4 +73,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.");
+ }
}
