From 6cd5c8db6a48d8f271ebec44ed99040c60057b89 Mon Sep 17 00:00:00 2001
From: eeff <eeff at eeff dot dev>
Date: Thu, 27 Jan 2022 15:26:38 +0800
Subject: [PATCH] Update persist adapter to load subscription infos

---
 src/adapter/adapter.c | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/src/adapter/adapter.c b/src/adapter/adapter.c
index 1c27b5f9..98dbdfd6 100644
--- a/src/adapter/adapter.c
+++ b/src/adapter/adapter.c
@@ -510,9 +510,15 @@ static int persister_singleton_load_data(neu_adapter_t *adapter)
         }
     }
 
-    neu_persist_adapter_infos_free(adapter_infos);
-
-    return rv;
+    VECTOR_FOR_EACH(adapter_infos, iter)
+    {
+        neu_persist_adapter_info_t *adapter_info = iterator_get(&iter);
+        rv =
+            persister_singleton_load_subscriptions(adapter, adapter_info->name);
+        if (0 != rv) {
+            break;
+        }
+    }
 
 error_add_adapters:
     neu_persist_adapter_infos_free(adapter_infos);