|
|
@@ -139,7 +139,7 @@ class RuleAbstractClusterUniqueTask extends AbstractClusterUniqueTask implements
|
|
|
public Mono<Void> handlePing(AbstractClusterUniqueTask task) {
|
|
|
//心跳信息
|
|
|
RuleAbstractClusterUniqueTask uniqueTask = (RuleAbstractClusterUniqueTask) task;
|
|
|
- if (task.getCurrentSeverId().equals(this.getWorkerId())) {
|
|
|
+ if (this.getCurrentSeverId().equals(this.getWorkerId())) {
|
|
|
return Mono.empty();
|
|
|
}
|
|
|
this.setWorkerId(task.getCurrentSeverId());
|