diff --git a/src/main/java/cn/stock/market/listener/AppClient.java b/src/main/java/cn/stock/market/listener/AppClient.java
index 2f8f6aa..5babe1f 100644
--- a/src/main/java/cn/stock/market/listener/AppClient.java
+++ b/src/main/java/cn/stock/market/listener/AppClient.java
@@ -68,7 +68,7 @@ public class AppClient implements OmmConsumerClient {
         return messageFuture;
     }
 
-    private void resetMessageFuture() {
+    public void resetMessageFuture() {
         this.messageFuture = new CompletableFuture<>();
     }
 
diff --git a/src/main/java/cn/stock/market/web/MessageRetifiveController.java b/src/main/java/cn/stock/market/web/MessageRetifiveController.java
index 845c0f9..9df59dc 100644
--- a/src/main/java/cn/stock/market/web/MessageRetifiveController.java
+++ b/src/main/java/cn/stock/market/web/MessageRetifiveController.java
@@ -59,6 +59,9 @@ public class MessageRetifiveController {
             return ServerResponse.createBySuccess("操作成功",refreshMsg.toString());
         } catch (Exception e) {
             return ServerResponse.createByError();
+        } finally {
+            // 可能需要重置或清理资源
+            appClient.resetMessageFuture();
         }
     }
 
@@ -85,6 +88,9 @@ public class MessageRetifiveController {
             } catch (Exception e) {
                 log.error("获取列表异常link:"+nextLink,e);
                 return ServerResponse.createByError();
+            } finally {
+                // 可能需要重置或清理资源
+                appClient.resetMessageFuture();
             }
         }
         return ServerResponse.createBySuccess("操作成功");
@@ -158,6 +164,9 @@ public class MessageRetifiveController {
                         }
                     } catch (Exception e) {
                         log.error("获取列表异常link:"+itemName,e);
+                    } finally {
+                        // 可能需要重置或清理资源
+                        appClient.resetMessageFuture();
                     }
         }
 
@@ -183,6 +192,9 @@ public class MessageRetifiveController {
                 }
             } catch (Exception e) {
                 log.error("获取股票详情link:"+itemName,e);
+            } finally {
+                // 可能需要重置或清理资源
+                appClient.resetMessageFuture();
             }
 
         return ServerResponse.createBySuccess("操作成功");
@@ -206,6 +218,9 @@ public class MessageRetifiveController {
                 }
             } catch (Exception e) {
                 log.error("获取股票详情link:"+name,e);
+            } finally {
+                // 可能需要重置或清理资源
+                appClient.resetMessageFuture();
             }
         }
         return ServerResponse.createBySuccess("操作成功",list);
@@ -236,6 +251,9 @@ public class MessageRetifiveController {
             }
         } catch (Exception e) {
             log.error("获取股票详情link:"+name,e);
+        } finally {
+            // 可能需要重置或清理资源
+            appClient.resetMessageFuture();
         }
         return ServerResponse.createBySuccess("操作成功",list);
     }
@@ -261,6 +279,9 @@ public class MessageRetifiveController {
             }
         } catch (Exception e) {
             log.error("获取股票详情link:"+name,e);
+        } finally {
+            // 可能需要重置或清理资源
+            appClient.resetMessageFuture();
         }
         return ServerResponse.createBySuccess("操作成功",list);
     }
@@ -288,6 +309,9 @@ public class MessageRetifiveController {
             }
         } catch (Exception e) {
             log.error("获取股票详情link:"+name,e);
+        } finally {
+            // 可能需要重置或清理资源
+            appClient.resetMessageFuture();
         }
         return ServerResponse.createBySuccess("操作成功",list);
     }
diff --git a/src/main/java/cn/stock/market/web/RefinitivApiController.java b/src/main/java/cn/stock/market/web/RefinitivApiController.java
index 14c19f1..39bd191 100644
--- a/src/main/java/cn/stock/market/web/RefinitivApiController.java
+++ b/src/main/java/cn/stock/market/web/RefinitivApiController.java
@@ -62,6 +62,9 @@ public class RefinitivApiController {
             }
         } catch (Exception e) {
             log.error("获取股票详情link:" + symbol, e);
+        } finally {
+            // 可能需要重置或清理资源
+            appClient.resetMessageFuture();
         }
 
         return ServerResponse.createBySuccess("操作成功");
@@ -86,6 +89,9 @@ public class RefinitivApiController {
                 }
             } catch (Exception e) {
                 log.error("获取股票详情link:" + name, e);
+            } finally {
+                // 可能需要重置或清理资源
+                appClient.resetMessageFuture();
             }
         }
         return ServerResponse.createBySuccess("操作成功", list);
@@ -121,6 +127,9 @@ public class RefinitivApiController {
             }
         } catch (Exception e) {
             log.error("获取股票详情link:" + name, e);
+        } finally {
+            // 可能需要重置或清理资源
+            appClient.resetMessageFuture();
         }
 
         return ServerResponse.createBySuccess("操作成功", list);
@@ -154,6 +163,9 @@ public class RefinitivApiController {
             }
         } catch (Exception e) {
             log.error("获取股票详情link:" + name, e);
+        } finally {
+            // 可能需要重置或清理资源
+            appClient.resetMessageFuture();
         }
 
         return ServerResponse.createBySuccess("操作成功", list);
@@ -188,6 +200,9 @@ public class RefinitivApiController {
             }
         } catch (Exception e) {
             log.error("获取股票详情link:"+name,e);
+        } finally {
+            // 可能需要重置或清理资源
+            appClient.resetMessageFuture();
         }
         return ServerResponse.createBySuccess("操作成功",list);
     }