unlock mq

ipconfiger · ipconfiger · commit d1d4e60b94bd · 2024-03-01T08:31:38.000+08:00
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!("没有可用发送端口");

Original file line number	Diff line number	Diff line change
`@@ -599,7 +599,7 @@ fn worker_body(thread_id: usize, rx: Receiver<RowEvents>, mapping: &mut TableMet`
`599`	`599`	`if ports.len() > 0 {`
`600`	`600`	`for (mq_name, topic) in ports {`
`601`	`601`	`let msg_qu = QueueMessage { topic, payload: json_str.clone(), pos };`
`602`		`- //queue.push(&mq_name, msg_qu);`
	`602`	`+ queue.push(&mq_name, msg_qu);`
`603`	`603`	`}`
`604`	`604`	`}else{`
`605`	`605`	`warn!("没有可用发送端口");`