Skip to content

Commit 39e687c

Browse files
committed
Fixed a bug with zookeeper integration for code generation locks
1 parent ce336bb commit 39e687c

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/main/java/org/computate/frFR/java/RegarderRepertoire.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -590,13 +590,15 @@ protected Path enregistrerTout(final Path demarrer) throws IOException {
590590
private void regarderClasseEvenement(Message<Object> message) {
591591
workerExecutor.executeBlocking(() -> {
592592
Promise<Void> promise = Promise.promise();
593+
String zookeeperNodeName = null;
594+
Stat zookeeperStat = null;
593595
try {
594596
JsonObject body = ((JsonObject)message.body()).getJsonObject("context").getJsonObject("params").getJsonObject("body");
595597
String cheminCompletStr = body.getString("cheminComplet");
596598
LOG.debug(String.format("Received request on the event bus: %s", cheminCompletStr));
597599
Path cheminComplet = Path.of(cheminCompletStr);
598-
Stat zookeeperStat = new Stat();
599-
String zookeeperNodeName = String.format("/%s%s", ZOOKEEPER_ROOT_PATH, cheminCompletStr.replace("/", "-"));
600+
zookeeperStat = new Stat();
601+
zookeeperNodeName = String.format("/%s/%s", ZOOKEEPER_ROOT_PATH, cheminCompletStr.replace("/", "-"));
600602
zookeeper.create(zookeeperNodeName, "reserved".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL, zookeeperStat);
601603
String classeCheminAbsolu = cheminComplet.toAbsolutePath().toString();
602604
String cp = FileUtils.readFileToString(new File(COMPUTATE_SRC + "/config/cp.txt"), "UTF-8");

0 commit comments

Comments
 (0)