Method run

tutorial/MyGNode/MyPubMessageNode.h:25–31

    }

    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;