jiangjiazhi / center

Authored by maliang about 9 years ago

Exists in master

Showing 4 changed files with 20 additions and 20 deletions

...	...	@@ -5,7 +5,7 @@
5	5
6	6	import com.lyms.cm.entity.sys.SysRoles;
7	7	import com.lyms.cm.entity.sys.SysUsers;
8		-import com.lyms.synch.CenterCallback;
	8	+import com.lyms.synch.SyncCallback;
9	9	import com.lyms.synch.SyncnCenter;
10	10	import com.lyms.synch.SyncnCenter.Work;
11	11	import com.lyms.synch.entity.ModelType;
...	...	@@ -44,7 +44,7 @@
44	44	roles.setName("roles");
45	45	user.setRoles(roles);
46	46
47		- center.buildWork().push(model, new CenterCallback() {
	47	+ center.buildWork().push(model, new SyncCallback() {
48	48	@Override
49	49	public void callBack(Object object) {
50	50	System.out.println("push callBack : " + object);
...	...	@@ -85,7 +85,7 @@
85	85	Work work = center.buildWork();
86	86	try {
87	87	// final AckObj ack = new AckObj();
88		- work.pullTmp(new CenterCallback() {
	88	+ work.pullTmp(new SyncCallback() {
89	89	@Override
90	90	public void callBack(Object object) {
91	91	SyncnModel model = (SyncnModel) object;
...	...	@@ -110,7 +110,7 @@
110	110	Work work2 = center.buildWork();
111	111	try {
112	112	// final AckObj ack = new AckObj();
113		- work2.pullFix(new CenterCallback() {
	113	+ work2.pullFix(new SyncCallback() {
114	114	@Override
115	115	public void callBack(Object object) {
116	116	// remote

1		-package com.lyms.synch;
2		-
3		-/**
4		- * <li>@ClassName: CenterCallback
5		- * <li>@Description: 数据回调
6		- * <li>@author maliang
7		- * <li>@date 2017年3月14日
8		- * <li>
9		- */
10		-public interface CenterCallback {
11		- public void callBack(Object object);
12		-}

	1	+package com.lyms.synch;
	2	+
	3	+/**
	4	+ * <li>@ClassName: CenterCallback
	5	+ * <li>@Description: 数据回调
	6	+ * <li>@author maliang
	7	+ * <li>@date 2017年3月14日
	8	+ * <li>
	9	+ */
	10	+public interface SyncCallback {
	11	+ public void callBack(Object object);
	12	+}

...	...	@@ -66,7 +66,7 @@
66	66
67	67	// public CenterCallback callBack;
68	68
69		- public Work push(SyncnModel model, CenterCallback callBack) {
	69	+ public Work push(SyncnModel model, SyncCallback callBack) {
70	70	this.model = model;
71	71	Boolean tag = queue.push(model);
72	72	callBack.callBack(tag);
...	...	@@ -84,7 +84,7 @@
84	84	* <li>修改人：
85	85	* <li>修改时间：
86	86	*/
87		- public Work pullFix(CenterCallback callBack) {
	87	+ public Work pullFix(SyncCallback callBack) {
88	88	SyncnModel model = queue.pull(ModelType.GET);
89	89	this.model = model;
90	90	callBack.callBack(model);
...	...	@@ -102,7 +102,7 @@
102	102	* <li>修改人：
103	103	* <li>修改时间：
104	104	*/
105		- public Work pullTmp(CenterCallback callBack) {
	105	+ public Work pullTmp(SyncCallback callBack) {
106	106	SyncnModel model = queue.pull(null);
107	107	this.model = model;
108	108	callBack.callBack(model);
...	...	@@ -120,7 +120,7 @@
120	120	* <li>修改时间：
121	121	*/
122	122	public void backPressure() {
123		- this.push(model, new CenterCallback() {
	123	+ this.push(model, new SyncCallback() {
124	124	boolean tag = false;
125	125
126	126	@Override