Class MySubMessageNode

tutorial/MyGNode/MySubMessageNode.h:16–43

template <typename ...Args>
class MySubMessageNode : public CGraph::GTemplateNode<Args ...> {
public:
    explicit MySubMessageNode(int connId) {
        conn_id_ = connId;
    }

    CStatus init() override {
        CGraph::CGRAPH_ECHO("==> [%s] [init] get conn id = [%d]",
                            this->getName().c_str(), conn_id_);
        return CStatus();
    }

    CStatus run() override {
        std::shared_ptr<MyMessageParam> mp = nullptr;    // 通过智能指针类型，接收一个消息。相比value接收(Recv or Sub)，性能会好一些
        CStatus status = CGRAPH_SUB_MPARAM(MyMessageParam, conn_id_, mp)
        if (!status.isOK()) {
            CGraph::CGRAPH_ECHO("[%s] recv message error", this->getName().c_str());
            return status;
        }

        CGraph::CGRAPH_ECHO("[%s] conn id = [%d], num = [%d], info = [%s]",
                            this->getName().c_str(), conn_id_, mp->num, mp->info.c_str());
        return status;
    }

private:
    CIndex conn_id_;
};

#endif //CGRAPH_MYSUBMESSAGENODE_H