From ffa77b88b739f2d3328d63552be99408c422e6dc Mon Sep 17 00:00:00 2001
From: jruaux <jruaux@gmail.com>
Date: Wed, 12 Jun 2024 20:34:49 -0700
Subject: [PATCH] refactor: Renamed MemKeyValueFilter

---
 .../riot/{MemKeyValueFilter.java => KeyValueFilter.java}      | 4 ++--
 plugins/riot/src/main/java/com/redis/riot/Replicate.java      | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)
 rename plugins/riot/src/main/java/com/redis/riot/{MemKeyValueFilter.java => KeyValueFilter.java} (86%)

diff --git a/plugins/riot/src/main/java/com/redis/riot/MemKeyValueFilter.java b/plugins/riot/src/main/java/com/redis/riot/KeyValueFilter.java
similarity index 86%
rename from plugins/riot/src/main/java/com/redis/riot/MemKeyValueFilter.java
rename to plugins/riot/src/main/java/com/redis/riot/KeyValueFilter.java
index 9798f7108..46da48573 100644
--- a/plugins/riot/src/main/java/com/redis/riot/MemKeyValueFilter.java
+++ b/plugins/riot/src/main/java/com/redis/riot/KeyValueFilter.java
@@ -11,12 +11,12 @@
 
 import io.lettuce.core.codec.RedisCodec;
 
-public class MemKeyValueFilter<K, T extends KeyValue<K, ?>> implements ItemProcessor<T, T> {
+public class KeyValueFilter<K, T extends KeyValue<K, ?>> implements ItemProcessor<T, T> {
 
 	private final Function<K, String> keyToString;
 	private final Logger log;
 
-	public MemKeyValueFilter(RedisCodec<K, ?> codec, Logger log) {
+	public KeyValueFilter(RedisCodec<K, ?> codec, Logger log) {
 		this.keyToString = BatchUtils.toStringKeyFunction(codec);
 		this.log = log;
 	}
diff --git a/plugins/riot/src/main/java/com/redis/riot/Replicate.java b/plugins/riot/src/main/java/com/redis/riot/Replicate.java
index 5aeccbb62..dcc4d7855 100644
--- a/plugins/riot/src/main/java/com/redis/riot/Replicate.java
+++ b/plugins/riot/src/main/java/com/redis/riot/Replicate.java
@@ -76,7 +76,7 @@ protected boolean isIgnoreStreamMessageId() {
 	}
 
 	private ItemProcessor<KeyValue<byte[], Object>, KeyValue<byte[], Object>> processor() {
-		return RiotUtils.processor(new MemKeyValueFilter<>(ByteArrayCodec.INSTANCE, log), keyValueProcessor());
+		return RiotUtils.processor(new KeyValueFilter<>(ByteArrayCodec.INSTANCE, log), keyValueProcessor());
 	}
 
 	private ItemProcessor<KeyValue<byte[], Object>, KeyValue<byte[], Object>> keyValueProcessor() {