diff --git a/center.manager/src/test/java/center/manager/test/user/WorkTest.java b/center.manager/src/test/java/center/manager/test/user/WorkTest.java index c927da6..6870ce6 100644 --- a/center.manager/src/test/java/center/manager/test/user/WorkTest.java +++ b/center.manager/src/test/java/center/manager/test/user/WorkTest.java @@ -53,6 +53,7 @@ public class WorkTest extends BaseTest { // 包含ack 回调方法 Work work = center.buildWork(); try { + work.pullTmp(new CenterCallback() { @Override public void callBack(Object object) { diff --git a/core.sdk/src/main/java/com/lyms/synch/SyncnCenter.java b/core.sdk/src/main/java/com/lyms/synch/SyncnCenter.java index b235520..d7aef6f 100644 --- a/core.sdk/src/main/java/com/lyms/synch/SyncnCenter.java +++ b/core.sdk/src/main/java/com/lyms/synch/SyncnCenter.java @@ -71,6 +71,17 @@ public class SyncnCenter { return this; } + /** + *
+ * 该方法不需要业务自行反压数据 + *
+ * 该方法需要业务自行判断做数据反压 + *