modularization/src/test/testmodulecommextrecv/testfastrtpstcprecv.cpp

#include "testfastrtpstcprecv.h"

testfastrtpstcprecv::testfastrtpstcprecv()
{
    mpa = new iv::modulecommext::modulecommmsg<iv::testmodulecommext>();
    ModuleExtFun funext = std::bind(&testfastrtpstcprecv::ListenMsg,this,std::placeholders::_1);
    mpa->RegisterRecvPlus("test",funext,iv::modulecomm::ModuleComm_FASTRTPS_TCP,"192.168.14.98",5101);
}

void testfastrtpstcprecv::ListenMsg(google::protobuf::Message &xmsg)
{
    iv::testmodulecommext  xdata;
    xdata.CopyFrom(xmsg);
    qDebug("rtps_tcp: %lld",xdata.time());
}