Function pub_message

tutorial/T17-MessagePubSub.cpp:16–26

using namespace CGraph;

void pub_message() {
    CStatus status;
    GElementPtr node1, pubNode;
    GPipelinePtr pubPipeLine = GPipelineFactory::create();

    // 注册用于 发布 的pipeline
    status += pubPipeLine->registerGElement<MyNode1>(&node1, {}, "myNode1");
    status += pubPipeLine->registerGElement<MyPubMessageNode>(&pubNode, {});

    pubPipeLine->process(5);
}


void sub_message() {