Route cache evictions routing to CacheEvictionEventRouter
Fix an issue where the cache evictions events were broadcasted
to all nodes instead of being consumed and passed to the eviction
router for execution.
Bug: Issue 12273
Change-Id: I5e370b4d5702ecbc17097cff71353db09470e956
diff --git a/src/main/java/com/googlesource/gerrit/plugins/multisite/consumer/CacheEvictionEventSubscriber.java b/src/main/java/com/googlesource/gerrit/plugins/multisite/consumer/CacheEvictionEventSubscriber.java
index d096148..572d1a3 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/multisite/consumer/CacheEvictionEventSubscriber.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/multisite/consumer/CacheEvictionEventSubscriber.java
@@ -23,7 +23,7 @@
import com.googlesource.gerrit.plugins.multisite.broker.BrokerApiWrapper;
import com.googlesource.gerrit.plugins.multisite.broker.BrokerGson;
import com.googlesource.gerrit.plugins.multisite.forwarder.events.EventTopic;
-import com.googlesource.gerrit.plugins.multisite.forwarder.router.StreamEventRouter;
+import com.googlesource.gerrit.plugins.multisite.forwarder.router.CacheEvictionEventRouter;
import java.util.UUID;
@Singleton
@@ -31,7 +31,7 @@
@Inject
public CacheEvictionEventSubscriber(
BrokerApiWrapper brokerApi,
- StreamEventRouter eventRouter,
+ CacheEvictionEventRouter eventRouter,
DynamicSet<DroppedEventListener> droppedEventListeners,
@BrokerGson Gson gsonProvider,
@InstanceId UUID instanceId,
