From e0842b2ae175e438d959dc57613f649d42f0303f Mon Sep 17 00:00:00 2001 From: Jonathan Cobb Date: Sun, 29 Dec 2019 19:45:26 -0500 Subject: [PATCH] only send unlock message once --- .../main/java/bubble/service/boot/SageHelloService.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/bubble-server/src/main/java/bubble/service/boot/SageHelloService.java b/bubble-server/src/main/java/bubble/service/boot/SageHelloService.java index 7e38bed2..d73486ff 100644 --- a/bubble-server/src/main/java/bubble/service/boot/SageHelloService.java +++ b/bubble-server/src/main/java/bubble/service/boot/SageHelloService.java @@ -63,9 +63,11 @@ public class SageHelloService extends SimpleDaemon { log.info("hello_to_sage: received reply from sage node: " + json(receipt, COMPACT_MAPPER)); if (receipt.isSuccess()) { if (!sageHelloSent.get()) sageHelloSent.set(true); - if (unlockMessage.get() != null) { - final AccountMessageDAO messageDAO = c.getBean(AccountMessageDAO.class); - messageDAO.create(unlockMessage.get()); + synchronized (unlockMessage) { + if (unlockMessage.get() != null && !unlockMessage.get().hasUuid()) { + final AccountMessageDAO messageDAO = c.getBean(AccountMessageDAO.class); + unlockMessage.set(messageDAO.create(unlockMessage.get())); + } } } }