|
|
@@ -143,7 +143,7 @@ public abstract class AbstractClusterUniqueTask<T> implements Serializable, Clus
|
|
|
}
|
|
|
}else {
|
|
|
beMasterFirst=true;
|
|
|
- this.setWorkerId(null);
|
|
|
+// this.setWorkerId(null);
|
|
|
if(this.generatePingMsgDisposable!=null&&!this.generatePingMsgDisposable.isDisposed()){
|
|
|
this.generatePingMsgDisposable.dispose();
|
|
|
}
|
|
|
@@ -202,6 +202,7 @@ public abstract class AbstractClusterUniqueTask<T> implements Serializable, Clus
|
|
|
Object message = obj.getMessage();
|
|
|
this.isAlive.set(true);
|
|
|
if (message instanceof AbstractClusterUniqueTask) {
|
|
|
+ this.workerId=((AbstractClusterUniqueTask) message).getWorkerId();
|
|
|
return handlePing((AbstractClusterUniqueTask) message);
|
|
|
}
|
|
|
return handleMsg(message);
|