|
|
@@ -157,11 +157,8 @@ class ClusterUniqueTask implements Task ,Serializable{
|
|
|
context.setJob(old);
|
|
|
throw e;
|
|
|
}
|
|
|
- }).concatWith(Mono.fromRunnable(
|
|
|
- ()->
|
|
|
- this.clusterManager.getTopic(this.operationTopic)
|
|
|
- .publish(Mono.just(OperationMessage.of(TaskOperation.JOB,Collections.singletonList(job),this.currentSeverId)))
|
|
|
- .then()))
|
|
|
+ }).concatWith(this.clusterManager.getTopic(this.operationTopic)
|
|
|
+ .publish(Mono.just(OperationMessage.of(TaskOperation.JOB,Collections.singletonList(job),this.currentSeverId))))
|
|
|
.then();
|
|
|
|
|
|
}
|
|
|
@@ -306,11 +303,8 @@ class ClusterUniqueTask implements Task ,Serializable{
|
|
|
@Override
|
|
|
public Mono<Void> reload() {
|
|
|
return operation(OperationMessage.of(TaskOperation.RELOAD,currentSeverId))
|
|
|
- .concatWith(Mono.fromRunnable(
|
|
|
- ()->
|
|
|
- this.clusterManager.getTopic(this.operationTopic)
|
|
|
- .publish(Mono.just(OperationMessage.of(TaskOperation.RELOAD,null,this.currentSeverId)))
|
|
|
- .then()))
|
|
|
+ .concatWith(this.clusterManager.getTopic(this.operationTopic)
|
|
|
+ .publish(Mono.just(OperationMessage.of(TaskOperation.RELOAD,null,this.currentSeverId))).then())
|
|
|
.then();
|
|
|
}
|
|
|
|