Lines Matching refs:topicName
24 md->topicName = aTopicName; in NewMessageData()
151 static char isTopicMatched(char* topicFilter, MQTTString* topicName) in isTopicMatched() argument
154 char* curn = topicName->lenstring.data; in isTopicMatched()
155 char* curn_end = curn + topicName->lenstring.len; in isTopicMatched()
179 int deliverMessage(MQTTClient* c, MQTTString* topicName, MQTTMessage* message) in deliverMessage() argument
187 …if (c->messageHandlers[i].topicFilter != 0 && (MQTTPacket_equals(topicName, (char*)c->messageHandl… in deliverMessage()
188 isTopicMatched((char*)c->messageHandlers[i].topicFilter, topicName))) in deliverMessage()
193 NewMessageData(&md, topicName, message); in deliverMessage()
203 NewMessageData(&md, topicName, message); in deliverMessage()
279 MQTTString topicName; in cycle() local
283 if (MQTTDeserialize_publish(&msg.dup, &intQoS, &msg.retained, &msg.id, &topicName, in cycle()
287 deliverMessage(c, &topicName, &msg); in cycle()
617 int MQTTPublish(MQTTClient* c, const char* topicName, MQTTMessage* message) in MQTTPublish() argument
622 topic.cstring = (char *)topicName; in MQTTPublish()