| 15 | class MyRecvMessageNode : public CGraph::GNode { |
| 16 | public: |
| 17 | CStatus run() override { |
| 18 | std::shared_ptr<MyMessageParam> mp = nullptr; // 接收一个消息 |
| 19 | CStatus status = CGRAPH_RECV_MPARAM(MyMessageParam, "send-recv", mp); |
| 20 | if (!status.isOK()) { |
| 21 | CGraph::CGRAPH_ECHO("MySubMessageNode sub message error"); |
| 22 | return status; |
| 23 | } |
| 24 | |
| 25 | CGraph::CGRAPH_ECHO("num = [%d], info = [%s]", mp->num, mp->info.c_str()); |
| 26 | return status; |
| 27 | } |
| 28 | }; |
| 29 | |
| 30 | #endif //CGRAPH_MYRECVMESSAGENODE_H |
nothing calls this directly
no test coverage detected