jiangjiazhi / center

Commit 44918fa24721761a920c3a5eb77886bc5b2341bd

Authored by maliang over 9 years ago

Exists in master

修改测试文件

Showing 1 changed file with 28 additions and 22 deletions

center.manager/src/test/java/center/manager/test/user/WorkTest.java

...	...	@@ -30,7 +30,7 @@
30	30	model.setId(StrUtils.uuid());
31	31	model.setModel("user2");
32	32	model.setMethod("post");
33		- model.setType(ModelType.GET.name());
	33	+ model.setType(ModelType.ADD.name());
34	34	// 推送数据远程地址
35	35	model.setRemote("http://127.0.0.1:9090/center.manager/remote/push");
36	36	// 对于远程获取数据，回调地址
37	37
38	38
...	...	@@ -41,26 +41,35 @@
41	41	user.setName("乱码测试");
42	42	model.setData(user);
43	43
44		- // 添加任务信息,临时任务信息 ModelType.Get()固定任务
45		- /*
46		- * center.buildWork().push(model, new CenterCallback() {
47		- *
48		- * @Override public void callBack(Object object) {
49		- * System.out.println("push callBack : " + object); } });
50		- */
	44	+ center.buildWork().push(model, new CenterCallback() {
51	45
52		- /*
53		- * Work work = center.buildWork(); try {
54		- *
55		- * work.pullFix(new CenterCallback() {
56		- *
57		- * @Override public void callBack(Object object) { // 处理实际业务 SyncnModel
58		- * model = (SyncnModel) object; // String result =
59		- * HttpUtils.REMOTE.post(model); System.out.println(model.getModel()); }
60		- * }); } catch (Exception e) { e.printStackTrace(); // 临时队列数据，需要手动反压
61		- * work.backPressure(); }
62		- */
	46	+ @Override
	47	+ public void callBack(Object object) {
	48	+ System.out.println("push callBack : " + object);
	49	+ }
	50	+ });
63	51
	52	+ }
	53	+
	54	+ @Test
	55	+ public void tmp() {
	56	+ Work work = center.buildWork();
	57	+ try {
	58	+ work.pullTmp(new CenterCallback() {
	59	+ @Override
	60	+ public void callBack(Object object) {
	61	+ System.out.println("pull callBack : " + object);
	62	+ }
	63	+ });
	64	+ } catch (Exception e) {
	65	+ e.printStackTrace();
	66	+ // 异常数据反压
	67	+ work.backPressure();
	68	+ }
	69	+ }
	70	+
	71	+ @Test
	72	+ public void fix() throws InterruptedException {
64	73	// 获取固定任务队列任务
65	74	// 包含ack 回调方法
66	75	while (true) {
...	...	@@ -81,9 +90,6 @@
81	90	}
82	91	Thread.sleep(3000);
83	92	}
84		- // .ackGet(null);
85		- // System.out.println("callBack: " + get);
86		-
87	93	}
88	94
89	95	public static void main(String[] args) {