diff --git a/src/org/redkale/service/DataCacheListenerService.java b/src/org/redkale/service/DataCacheListenerService.java
index e1d2919e1..08cac736b 100644
--- a/src/org/redkale/service/DataCacheListenerService.java
+++ b/src/org/redkale/service/DataCacheListenerService.java
@@ -11,6 +11,7 @@ import org.redkale.source.*;
 import org.redkale.util.*;
 
 /**
+ * 实现进程间DataSource的缓存数据同步
  *
  * <p>
  * 详情见: https://redkale.org
@@ -27,18 +28,21 @@ public class DataCacheListenerService implements DataCacheListener, Service {
     @Override
     @RpcMultiRun(selfrun = false, async = true)
     public <T> int insertCache(Class<T> clazz, T... entitys) {
+        if (!(source instanceof DataCacheListener)) return -2;
         return ((DataCacheListener) source).insertCache(clazz, entitys);
     }
 
     @Override
     @RpcMultiRun(selfrun = false, async = true)
     public <T> int updateCache(Class<T> clazz, T... entitys) {
+        if (!(source instanceof DataCacheListener)) return -2;
         return ((DataCacheListener) source).updateCache(clazz, entitys);
     }
 
     @Override
     @RpcMultiRun(selfrun = false, async = true)
     public <T> int deleteCache(Class<T> clazz, Serializable... ids) {
+        if (!(source instanceof DataCacheListener)) return -2;
         return ((DataCacheListener) source).deleteCache(clazz, ids);
     }