diff --git a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/service/voice/TtsQueueConsumer.java b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/service/voice/TtsQueueConsumer.java
index 6e60f9b..0426ff2 100644
--- a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/service/voice/TtsQueueConsumer.java
+++ b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/service/voice/TtsQueueConsumer.java
@@ -17,6 +17,7 @@ import org.springframework.stereotype.Service;
 
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.TimeUnit;
 
@@ -212,7 +213,7 @@ public class TtsQueueConsumer {
         try {
             // 获取所有队列 key
             String pattern = QUEUE_KEY_PREFIX + "*";
-            List<String> keys = redisTemplate.keys(pattern);
+            Set<String> keys = redisTemplate.keys(pattern);
 
             if (keys == null || keys.isEmpty()) {
                 return 0;
@@ -339,7 +340,7 @@ public class TtsQueueConsumer {
      */
     public void clearAllQueues() {
         String pattern = QUEUE_KEY_PREFIX + "*";
-        List<String> keys = redisTemplate.keys(pattern);
+        Set<String> keys = redisTemplate.keys(pattern);
         if (keys != null && !keys.isEmpty()) {
             redisTemplate.delete(keys);
             deviceBroadcastLock.clear();
@@ -354,7 +355,7 @@ public class TtsQueueConsumer {
         Map<String, Object> status = new ConcurrentHashMap<>();
 
         String pattern = QUEUE_KEY_PREFIX + "*";
-        List<String> keys = redisTemplate.keys(pattern);
+        Set<String> keys = redisTemplate.keys(pattern);
 
         if (keys != null && !keys.isEmpty()) {
             for (String key : keys) {