lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2017-03-21 09:34:35 +08:00
parent 15e03c0459
commit c4923f317b
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/org/redkale/service/DataCacheListenerService.java
View File

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