diff --git a/plugins/riot/src/test/java/com/redis/riot/RiotTests.java b/plugins/riot/src/test/java/com/redis/riot/RiotTests.java index 2a304c329..6a3cca29f 100644 --- a/plugins/riot/src/test/java/com/redis/riot/RiotTests.java +++ b/plugins/riot/src/test/java/com/redis/riot/RiotTests.java @@ -41,11 +41,6 @@ void replicateLive(TestInfo info) throws Exception { runLiveReplication(info, "replicate-live"); } - @Test - void replicateLiveThreads(TestInfo info) throws Exception { - runLiveReplication(info, "replicate-live-threads"); - } - protected void runLiveReplication(TestInfo info, String filename) throws Exception { DataType[] types = new DataType[] { DataType.HASH, DataType.STRING }; enableKeyspaceNotifications(); diff --git a/plugins/riot/src/test/java/com/redis/riot/StackRiotTests.java b/plugins/riot/src/test/java/com/redis/riot/StackRiotTests.java index 465c50b73..2ca569738 100644 --- a/plugins/riot/src/test/java/com/redis/riot/StackRiotTests.java +++ b/plugins/riot/src/test/java/com/redis/riot/StackRiotTests.java @@ -598,6 +598,11 @@ void replicateKeyProcessor(TestInfo info) throws Throwable { void replicateLiveStruct(TestInfo info) throws Exception { runLiveReplication(info, "replicate-live-struct"); } + + @Test + void replicateLiveThreads(TestInfo info) throws Exception { + runLiveReplication(info, "replicate-live-threads"); + } @Test void replicateLiveKeySlot(TestInfo info) throws Exception {