Lines Matching defs:data_message_stanza
870 const mcs_proto::DataMessageStanza& data_message_stanza =
873 DCHECK_EQ(data_message_stanza.device_user_id(), kDefaultUserSerialNumber);
879 for (int i = 0; i < data_message_stanza.app_data_size(); ++i) {
880 std::string key = data_message_stanza.app_data(i).key();
881 message_data[key] = data_message_stanza.app_data(i).value();
893 HandleIncomingDataMessage(data_message_stanza, message_data);
896 recorder_.RecordDataMessageReceived(data_message_stanza.category(),
897 data_message_stanza.from(),
898 data_message_stanza.ByteSize(),
901 delegate_->OnMessagesDeleted(data_message_stanza.category());
904 HandleIncomingSendError(data_message_stanza, message_data);
909 << "App ID: " << data_message_stanza.category() << ".";
915 const mcs_proto::DataMessageStanza& data_message_stanza,
917 std::string app_id = data_message_stanza.category();
926 data_message_stanza.from()) == iter->second->sender_ids.end();
927 recorder_.RecordDataMessageReceived(app_id, data_message_stanza.from(),
928 data_message_stanza.ByteSize(), !not_registered,
935 incoming_message.sender_id = data_message_stanza.from();
936 if (data_message_stanza.has_token())
937 incoming_message.collapse_key = data_message_stanza.token();
943 const mcs_proto::DataMessageStanza& data_message_stanza,
957 data_message_stanza.category(),
958 data_message_stanza.to(),
959 data_message_stanza.id());
960 delegate_->OnMessageSendError(data_message_stanza.category(),