unlock mq

ipconfiger · Mar 1, 2024 · d1d4e60 · d1d4e60
1 parent a5f0693
commit d1d4e60
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/executor.rs b/src/executor.rs
@@ -599,7 +599,7 @@ fn worker_body(thread_id: usize, rx: Receiver<RowEvents>, mapping: &mut TableMet
                         if ports.len() > 0 {
                             for (mq_name, topic) in ports {
                                 let msg_qu = QueueMessage { topic, payload: json_str.clone(), pos };
-                                //queue.push(&mq_name, msg_qu);
+                                queue.push(&mq_name, msg_qu);
                             }
                         }else{
                             warn!("没有可用发送端口");