MQTTAgent_CommandLoop

Process commands from the command queue in a loop.

MQTTStatus_t MQTTAgent_CommandLoop( MQTTAgentContext_t * pMqttAgentContext );

Parameters

[in]

pMqttAgentContext

The MQTT agent to use.

Returns

appropriate error code, or MQTTSuccess from a successful disconnect or termination.

Example

// Variables used in this example.
MQTTStatus_t status;
MQTTAgentContext_t mqttAgentContext;
 
status = MQTTAgent_CommandLoop( &mqttAgentContext );
 
// The function returns on either receiving a terminate command,
// undergoing network disconnection OR encountering an error.
if( ( status == MQTTSuccess ) && ( mqttAgentContext.mqttContext.connectStatus == MQTTNotConnected ) )
{
   // A terminate command was processed and MQTT connection was closed.
   // Need to close socket connection.
   Platform_DisconnectNetwork( mqttAgentContext.mqttContext.transportInterface.pNetworkContext );
}
else if( status == MQTTSuccess )
{
   // Terminate command was processed but MQTT connection was not
   // closed. Thus, need to close both MQTT and socket connections.
   status = MQTT_Disconnect( &( mqttAgentContext.mqttContext ) );
   assert( status == MQTTSuccess );
   Platform_DisconnectNetwork( mqttAgentContext.mqttContext.transportInterface.pNetworkContext );
}
else
{
    // Handle error.
}