|
@@ -93,22 +93,22 @@ Error_manager System_communication_mq::execute_dispatch_status_msg(Rabbitmq_mess
|
|
|
if( p_msg->m_routing_key == "user_command_port" )
|
|
|
{
|
|
|
park_table t_park_table_msg; //存车表单
|
|
|
- m_measure_statu_msg_2 = *p_msg;
|
|
|
+ LOG(INFO) << " huli test::t_string p_msg->m_message_buf = "<< p_msg->m_message_buf << " --- " << this;
|
|
|
if(google::protobuf::TextFormat::ParseFromString(p_msg->m_message_buf, &t_park_table_msg))
|
|
|
{
|
|
|
std::string t_string = t_park_table_msg.DebugString();
|
|
|
LOG(INFO) << " huli test::t_string = t_park_table_msg "<< t_string << " --- " ;
|
|
|
- //给唐有成, 这里面有terminal_id, 可以触发感测节点保存事件.
|
|
|
+ //给唐有成, 这里面有terminal_id(范围1-6), 可以触发感测节点保存事件.
|
|
|
//..............................
|
|
|
|
|
|
|
|
|
|
|
|
//指令信息必须手动ack, 这样才能清除服务器的指令,
|
|
|
//(状态消息临时队列接受后自动清除, 指令消息永久队列接收后手动清除)
|
|
|
- ack_msg(p_msg);
|
|
|
|
|
|
- }
|
|
|
|
|
|
+ }
|
|
|
+ ack_msg(p_msg);
|
|
|
}
|
|
|
|
|
|
|