jiangjiazhi / center

Authored by maliang about 9 years ago

Exists in master

Showing 2 changed files with 23 additions and 0 deletions

...	...	@@ -53,6 +53,7 @@
53	53	// 包含ack 回调方法
54	54	Work work = center.buildWork();
55	55	try {
	56	+
56	57	work.pullTmp(new CenterCallback() {
57	58	@Override
58	59	public void callBack(Object object) {

...	...	@@ -71,6 +71,17 @@
71	71	return this;
72	72	}
73	73
	74	+ /**
	75	+ * <li>@Description:固定任务队列
	76	+ * <p>
	77	+ * 该方法不需要业务自行反压数据
	78	+ * <li>@param callBack
	79	+ * <li>@return
	80	+ * <li>创建人：maliang
	81	+ * <li>创建时间：2017年3月13日
	82	+ * <li>修改人：
	83	+ * <li>修改时间：
	84	+ */
74	85	public Work pullFix(CenterCallback callBack) {
75	86	SyncnModel model = queue.pull(ModelType.GET);
76	87	this.model = model;
...	...	@@ -78,6 +89,17 @@
78	89	return this;
79	90	}
80	91
	92	+ /**
	93	+ * <li>@Description:获取临时任务信息
	94	+ * <p>
	95	+ * 该方法需要业务自行判断做数据反压
	96	+ * <li>@param callBack
	97	+ * <li>@return
	98	+ * <li>创建人：maliang
	99	+ * <li>创建时间：2017年3月13日
	100	+ * <li>修改人：
	101	+ * <li>修改时间：
	102	+ */
81	103	public Work pullTmp(CenterCallback callBack) {
82	104	SyncnModel model = queue.pull(null);
83	105	this.model = model;