From 44918fa24721761a920c3a5eb77886bc5b2341bd Mon Sep 17 00:00:00 2001
From: maliang <maliang@lymsh.com>
Date: Mon, 13 Mar 2017 17:01:06 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=B5=8B=E8=AF=95=E6=96=87?=
 =?UTF-8?q?=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/center/manager/test/user/WorkTest.java    | 50 ++++++++++++----------
 1 file changed, 28 insertions(+), 22 deletions(-)

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 37be4d0..7e962ff 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
@@ -30,7 +30,7 @@ public class WorkTest extends BaseTest {
 		model.setId(StrUtils.uuid());
 		model.setModel("user2");
 		model.setMethod("post");
-		model.setType(ModelType.GET.name());
+		model.setType(ModelType.ADD.name());
 		// 推送数据远程地址
 		model.setRemote("http://127.0.0.1:9090/center.manager/remote/push");
 		// 对于远程获取数据，回调地址
@@ -41,26 +41,35 @@ public class WorkTest extends BaseTest {
 		user.setName("乱码测试");
 		model.setData(user);
 
-		// 添加任务信息,临时任务信息 ModelType.Get()固定任务
-		/*
-		 * center.buildWork().push(model, new CenterCallback() {
-		 * 
-		 * @Override public void callBack(Object object) {
-		 * System.out.println("push callBack : " + object); } });
-		 */
+		center.buildWork().push(model, new CenterCallback() {
+
+			@Override
+			public void callBack(Object object) {
+				System.out.println("push callBack : " + object);
+			}
+		});
+
+	}
 
-		/*
-		 * Work work = center.buildWork(); try {
-		 * 
-		 * work.pullFix(new CenterCallback() {
-		 * 
-		 * @Override public void callBack(Object object) { // 处理实际业务 SyncnModel
-		 * model = (SyncnModel) object; // String result =
-		 * HttpUtils.REMOTE.post(model); System.out.println(model.getModel()); }
-		 * }); } catch (Exception e) { e.printStackTrace(); // 临时队列数据，需要手动反压
-		 * work.backPressure(); }
-		 */
+	@Test
+	public void tmp() {
+		Work work = center.buildWork();
+		try {
+			work.pullTmp(new CenterCallback() {
+				@Override
+				public void callBack(Object object) {
+					System.out.println("pull callBack : " + object);
+				}
+			});
+		} catch (Exception e) {
+			e.printStackTrace();
+			// 异常数据反压
+			work.backPressure();
+		}
+	}
 
+	@Test
+	public void fix() throws InterruptedException {
 		// 获取固定任务队列任务
 		// 包含ack 回调方法
 		while (true) {
@@ -81,9 +90,6 @@ public class WorkTest extends BaseTest {
 			}
 			Thread.sleep(3000);
 		}
-		// .ackGet(null);
-		// System.out.println("callBack: " + get);
-
 	}
 
 	public static void main(String[] args) {
-- 
1.8.3.1