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