From c4923f317b07cf550f55a04d5d5acca405325e13 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Tue, 21 Mar 2017 09:34:35 +0800
Subject: [PATCH]

---
 src/org/redkale/service/DataCacheListenerService.java | 4 ++++
 1 file changed, 4 insertions(+)

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);
     }