74 : channel_name_(channel),
75 data_type_(type),
76 qos_depth_(qos_depth),
77 node_(node) {
78 std::string proto_desc;
79 message::ProtobufFactory::Instance()->GetDescriptorString(type,
80 &proto_desc);
81 if (proto_desc.empty()) {
82 AWARN <<
"cpp can't find proto_desc msgtype->" << data_type_;
83 return;
84 }
85 proto::RoleAttributes role_attr;
86 role_attr.set_channel_name(channel_name_);
87 role_attr.set_message_type(data_type_);
88 role_attr.set_proto_desc(proto_desc);
89 auto qos_profile = role_attr.mutable_qos_profile();
90 qos_profile->set_depth(qos_depth_);
91 writer_ = node_->
CreateWriter<message::PyMessageWrap>(role_attr);
92 }
auto CreateWriter(const proto::RoleAttributes &role_attr) -> std::shared_ptr< Writer< MessageT > >
Create a Writer with specific message type.