From 52ef72276b3a969627f43d323c421764643c6f37 Mon Sep 17 00:00:00 2001
From: maliang <maliang@lymsh.com>
Date: Mon, 13 Mar 2017 16:31:39 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=96=B9=E6=B3=95=E6=B3=A8?=
 =?UTF-8?q?=E9=87=8A=E4=BF=A1=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/center/manager/test/user/WorkTest.java    |  1 +
 .../src/main/java/com/lyms/synch/SyncnCenter.java  | 22 ++++++++++++++++++++++
 2 files changed, 23 insertions(+)

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;
 		}
 
+		/**
+		 * <li>@Description:固定任务队列
+		 * <p>
+		 * 该方法不需要业务自行反压数据
+		 * <li>@param callBack
+		 * <li>@return
+		 * <li>创建人：maliang
+		 * <li>创建时间：2017年3月13日
+		 * <li>修改人：
+		 * <li>修改时间：
+		 */
 		public Work pullFix(CenterCallback callBack) {
 			SyncnModel model = queue.pull(ModelType.GET);
 			this.model = model;
@@ -78,6 +89,17 @@ public class SyncnCenter {
 			return this;
 		}
 
+		/**
+		 * <li>@Description:获取临时任务信息
+		 * <p>
+		 * 该方法需要业务自行判断做数据反压
+		 * <li>@param callBack
+		 * <li>@return
+		 * <li>创建人：maliang
+		 * <li>创建时间：2017年3月13日
+		 * <li>修改人：
+		 * <li>修改时间：
+		 */
 		public Work pullTmp(CenterCallback callBack) {
 			SyncnModel model = queue.pull(null);
 			this.model = model;
-- 
1.8.3.1