| 14 | using namespace CGraph; |
| 15 | |
| 16 | void send_message() { |
| 17 | CStatus status; |
| 18 | GElementPtr a, b; |
| 19 | GPipelinePtr pubPipeLine = GPipelineFactory::create(); |
| 20 | |
| 21 | // 注册用于 发送 的pipeline |
| 22 | status += pubPipeLine->registerGElement<MyNode1>(&a, {}, "myNode1"); |
| 23 | status += pubPipeLine->registerGElement<MySendMessageNode>(&b, {a}); |
| 24 | |
| 25 | pubPipeLine->process(3); |
| 26 | } |
| 27 | |
| 28 | |
| 29 | void recv_message() { |