refactor: Removed dropped metric as already exposed in micrometer

redis · Oct 7, 2024 · c2c827c · c2c827c
1 parent 2589621
commit c2c827c
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/plugins/riot/src/main/java/com/redis/riot/Replicate.java b/plugins/riot/src/main/java/com/redis/riot/Replicate.java
@@ -11,7 +11,6 @@
 import com.redis.spring.batch.item.redis.RedisItemWriter;
 import com.redis.spring.batch.item.redis.common.KeyValue;
 import com.redis.spring.batch.item.redis.reader.KeyComparisonItemReader;
-import com.redis.spring.batch.item.redis.reader.KeyEventStatus;
 import com.redis.spring.batch.item.redis.reader.KeyNotificationItemReader;
 
 import io.lettuce.core.codec.ByteArrayCodec;
@@ -29,7 +28,7 @@ public enum CompareMode {
 	public static final String STEP_NAME = "replicate";
 	public static final CompareMode DEFAULT_COMPARE_MODE = CompareMode.QUICK;
 
-	private static final String QUEUE_MESSAGE = " | capacity: %,d | dropped: %,d";
+	private static final String QUEUE_MESSAGE = " | capacity: %,d";
 	private static final String SCAN_TASK_NAME = "Scanning";
 	private static final String LIVEONLY_TASK_NAME = "Listening";
 	private static final String LIVE_TASK_NAME = "Scanning/Listening";
@@ -132,8 +131,7 @@ private String liveExtraMessage(RedisItemReader<?, ?, ?> reader) {
 		if (keyReader == null || keyReader.getQueue() == null) {
 			return "";
 		}
-		return String.format(QUEUE_MESSAGE, keyReader.getQueue().remainingCapacity(),
-				keyReader.count(KeyEventStatus.DROPPED));
+		return String.format(QUEUE_MESSAGE, keyReader.getQueue().remainingCapacity());
 	}
 
 	@Override