Merge branch 'stable-3.9' into stable-3.10
* stable-3.9:
RabbitMqBrokerApi.java: Removed unused logger
Change-Id: I38f3fd4322421f48c000dbcd1bb14b387e3937fa
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 e0a2a01..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,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.util.concurrent.ListenableFuture;
import com.google.gerrit.server.events.Event;
@@ -72,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.");
+ }
}
