|
@@ -83,15 +83,15 @@ namespace ct_terminal
|
|
|
m_car_number_condition = true;
|
|
|
m_car_number_thread = new Thread(get_car_number_thread);
|
|
|
|
|
|
- //初始化发送指令
|
|
|
- m_producer.producer_init(m_rabbitmq_ip, m_rabbitmq_port, m_rabbitmq_user, m_rabbitmq_password);
|
|
|
- //初始化消费指令
|
|
|
- string t_park_queue_key = "park_response_" + m_ternimalID.ToString() + "_queue";
|
|
|
- m_park_consumer.consumer_init(m_rabbitmq_ip, m_rabbitmq_port, m_rabbitmq_user, m_rabbitmq_password, t_park_queue_key, park_response_thread);
|
|
|
- //初始化消费指令
|
|
|
- string t_ex_name = "command_ex";
|
|
|
- string t_pick_queue_key = "pick_response_port";
|
|
|
- m_pick_consumer.consumer_undurable_init(m_rabbitmq_ip, m_rabbitmq_port, m_rabbitmq_user, m_rabbitmq_password, t_ex_name, t_pick_queue_key, pick_response_thread);
|
|
|
+ // //初始化发送指令
|
|
|
+ // m_producer.producer_init(m_rabbitmq_ip, m_rabbitmq_port, m_rabbitmq_user, m_rabbitmq_password);
|
|
|
+ // //初始化消费指令
|
|
|
+ // string t_park_queue_key = "park_response_" + m_ternimalID.ToString() + "_queue";
|
|
|
+ // m_park_consumer.consumer_init(m_rabbitmq_ip, m_rabbitmq_port, m_rabbitmq_user, m_rabbitmq_password, t_park_queue_key, park_response_thread);
|
|
|
+ // //初始化消费指令
|
|
|
+ // string t_ex_name = "command_ex";
|
|
|
+ // string t_pick_queue_key = "pick_response_port";
|
|
|
+ // m_pick_consumer.consumer_undurable_init(m_rabbitmq_ip, m_rabbitmq_port, m_rabbitmq_user, m_rabbitmq_password, t_ex_name, t_pick_queue_key, pick_response_thread);
|
|
|
}
|
|
|
private void MainForm_Load(object sender, EventArgs e)
|
|
|
{
|
|
@@ -111,9 +111,9 @@ namespace ct_terminal
|
|
|
m_car_number_thread.Start();
|
|
|
//启动打印机
|
|
|
PrintManual.Instance.Start();
|
|
|
- //启动接受反馈
|
|
|
- m_park_consumer.run();
|
|
|
- m_pick_consumer.run();
|
|
|
+ ////启动接受反馈
|
|
|
+ //m_park_consumer.run();
|
|
|
+ //m_pick_consumer.run();
|
|
|
|
|
|
//启动子程序
|
|
|
Process[] myprocess = Process.GetProcessesByName("UnNomalized_node");
|