diff --git a/services/distributeddataservice/service/rdb/rdb_service_impl.cpp b/services/distributeddataservice/service/rdb/rdb_service_impl.cpp
index b2d0164d168668d599b5d2736c2653e4ba8de585..f94089cd6409552118eb19c9963928ef5aa14e52 100644
--- a/services/distributeddataservice/service/rdb/rdb_service_impl.cpp
+++ b/services/distributeddataservice/service/rdb/rdb_service_impl.cpp
@@ -609,7 +609,7 @@ void RdbServiceImpl::DoCloudSync(const RdbSyncerParam &param, const RdbService::
 }
 
 int32_t RdbServiceImpl::Subscribe(const RdbSyncerParam &param, const SubscribeOption &option,
-    RdbStoreObserver *observer)
+    std::shared_ptr<RdbStoreObserver> observer)
 {
     if (option.mode < 0 || option.mode >= SUBSCRIBE_MODE_MAX) {
         ZLOGE("mode:%{public}d error", option.mode);
@@ -639,7 +639,7 @@ int32_t RdbServiceImpl::Subscribe(const RdbSyncerParam &param, const SubscribeOp
 }
 
 int32_t RdbServiceImpl::UnSubscribe(const RdbSyncerParam &param, const SubscribeOption &option,
-    RdbStoreObserver *observer)
+    std::shared_ptr<RdbStoreObserver> observer)
 {
     if (option.mode < 0 || option.mode >= SUBSCRIBE_MODE_MAX) {
         ZLOGE("mode:%{public}d error", option.mode);
diff --git a/services/distributeddataservice/service/rdb/rdb_service_impl.h b/services/distributeddataservice/service/rdb/rdb_service_impl.h
index e58c6618f209888d123b6d7f72dd164984f99a8b..47da7793f3f04659b8bb6ff603ca129108d44e46 100755
--- a/services/distributeddataservice/service/rdb/rdb_service_impl.h
+++ b/services/distributeddataservice/service/rdb/rdb_service_impl.h
@@ -66,10 +66,12 @@ public:
     int32_t Sync(const RdbSyncerParam &param, const Option &option, const PredicatesMemo &predicates,
         const AsyncDetail &async) override;
 
-    int32_t Subscribe(const RdbSyncerParam &param, const SubscribeOption &option, RdbStoreObserver *observer) override;
+    int32_t Subscribe(const RdbSyncerParam &param,
+                      const SubscribeOption &option,
+                      std::shared_ptr<RdbStoreObserver> observer) override;
 
     int32_t UnSubscribe(const RdbSyncerParam &param, const SubscribeOption &option,
-        RdbStoreObserver *observer) override;
+        std::shared_ptr<RdbStoreObserver>observer) override;
 
     int32_t RegisterAutoSyncCallback(const RdbSyncerParam& param,
         std::shared_ptr<DetailProgressObserver> observer) override;