in ports/IoT/include/iot/aia_iot_config.h [349:365]
inline bool AiaMqttSubscribe( AiaMqttConnectionPointer_t connection,
AiaMqttQos_t qos, const char* topic,
AiaMqttTopicHandler_t handler, void* userData )
{
IotMqttSubscription_t topicSubscription;
topicSubscription.qos = qos;
topicSubscription.pTopicFilter = topic;
topicSubscription.topicFilterLength = (uint16_t)strlen( topic );
topicSubscription.callback.function = handler;
topicSubscription.callback.pCallbackContext = userData;
return IOT_MQTT_SUCCESS ==
IotMqtt_TimedSubscribe( connection, &topicSubscription,
1, /* Subscribe to one topic at once */
0, /* No flags */
MQTT_TIMEOUT_MS ); /* Timeout - 5 seconds */
}