in source/core_mqtt_agent.c [1130:1151]
MQTTStatus_t MQTTAgent_Subscribe( const MQTTAgentContext_t * pMqttAgentContext,
MQTTAgentSubscribeArgs_t * pSubscriptionArgs,
const MQTTAgentCommandInfo_t * pCommandInfo )
{
MQTTStatus_t statusReturn = MQTTBadParameter;
bool paramsValid = false;
paramsValid = validateStruct( pMqttAgentContext, pCommandInfo ) &&
validateParams( SUBSCRIBE, pSubscriptionArgs );
if( paramsValid )
{
statusReturn = createAndAddCommand( SUBSCRIBE, /* commandType */
pMqttAgentContext, /* mqttContextHandle */
pSubscriptionArgs, /* pMqttInfoParam */
pCommandInfo->cmdCompleteCallback, /* commandCompleteCallback */
pCommandInfo->pCmdCompleteCallbackContext, /* pCommandCompleteCallbackContext */
pCommandInfo->blockTimeMs );
}
return statusReturn;
}