This commit is contained in:
Andrea Cavalli 2020-11-03 22:25:35 +01:00
parent 6201ce601e
commit 1690c082dc
1 changed files with 3 additions and 3 deletions

View File

@ -235,10 +235,10 @@ public class TDLibRemoteClient implements AutoCloseable {
if (lockAcquisitionResult.succeeded()) {
deploymentLock.set(lockAcquisitionResult.result());
var sharedData = clusterManager.getSharedData();
sharedData.getClusterWideMap("deployableBotAddresses", (AsyncResult<AsyncMap<String, String>> mapResult) -> {
sharedData.getClusterWideMap("runningBotAddresses", (AsyncResult<AsyncMap<String, String>> mapResult) -> {
if (mapResult.succeeded()) {
var deployableBotAddresses = mapResult.result();
deployableBotAddresses.removeIfPresent(botAddress, netInterface, putResult -> {
var runningBotAddresses = mapResult.result();
runningBotAddresses.removeIfPresent(botAddress, netInterface, putResult -> {
if (putResult.succeeded()) {
if (putResult.result() != null) {
handler.complete();