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
index c0a115620c2..73dd1ee41d1 100644
--- 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());