Class MyPubMessageNode

tutorial/MyGNode/MyPubMessageNode.h:15–35

#include "../MyParams/MyMessageParam.h"

class MyPubMessageNode : public CGraph::GNode {
public:
    CStatus init() override {
        int sleep = 300;
        CGRAPH_SLEEP_MILLISECOND(sleep)    // 休息，确保其他的sub节点，已经完成了订阅
        CGraph::CGRAPH_ECHO("==> [MyPubMessageNode] [init], sleep [%d] ms, to make sure sub node prepare ok.",
                            sleep);
        return CStatus();
    }

    CStatus run() override {
        std::shared_ptr<MyMessageParam> mp(new MyMessageParam());    // 创建一个消息，并且发送出去
        mp->num = (num_++) * 100;
        mp->info = "this is a test info, num = " + std::to_string(mp->num);
        CStatus status = CGRAPH_PUB_MPARAM(MyMessageParam, "pub-sub", mp, CGraph::GMessagePushStrategy::WAIT);
        return status;
    }

private:
    int num_ = 0;
};


#endif //CGRAPH_MYPUBMESSAGENODE_H