| 163 | |
| 164 | |
| 165 | static std::string DumpMessage(const std::list<MessageWrapper*>& _message_lst) { |
| 166 | XMessage xmsg; |
| 167 | xmsg(TSF"**************Dump MQ Message**************size:%_\n", _message_lst.size()); |
| 168 | int index = 0; |
| 169 | for (auto msg : _message_lst) { |
| 170 | xmsg(TSF"postid:%_, timing:%_, record_time:%_, message:%_\n", msg->postid.ToString(), msg->timing.ToString(), msg->record_time, msg->message.ToString()); |
| 171 | if (++index>50) |
| 172 | break; |
| 173 | } |
| 174 | return xmsg.String(); |
| 175 | } |
| 176 | std::string DumpMQ(const MessageQueue_t& _msq_queue_id) { |
| 177 | ScopedLock lock(sg_messagequeue_map_mutex); |
| 178 | const MessageQueue_t& id = _msq_queue_id; |
no test coverage detected