fix(event):synchronization of sending to zeromq (tronprotocol#5536)

Co-authored-by: paladim <paladim@example.com>
halibobo1205 · Oct 26, 2023 · 8de354f · 8de354f
1 parent 1ec48e1
commit 8de354f
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/framework/src/main/java/org/tron/common/logsfilter/nativequeue/NativeMessageQueue.java b/framework/src/main/java/org/tron/common/logsfilter/nativequeue/NativeMessageQueue.java
@@ -64,8 +64,10 @@ public void publishTrigger(String data, String topic) {
     }
 
     try {
-      publisher.sendMore(topic);
-      publisher.send(data);
+      synchronized (this) {
+        publisher.sendMore(topic);
+        publisher.send(data);
+      }
     } catch (RuntimeException e) {
       logger.error("write data to zeromq failed, data:{}, topic:{}, error:{}", data, topic,
           e.getMessage());