static MQTTStatus_t prvCreateMQTTConectionWithBroker( MQTTContext_t * pxMQTTContext, 
                                                      NetworkContext_t * pxNetworkContext )

{
    MQTTStatus_t xResult;
    MQTTConnectionInfo_t xConnectInfo;
    TransportInterface_t xTransport;

    /* Fill in Transport Interface send and receive function pointers. */
    xTransport.pNetworkContext = pxNetworkContext;
    xTransport.send = my_tls_send_function;
    xTransport.recv = my_tls_recv_function;

    /* Initialize MQTT library. */
    xResult = MQTT_Init( pxMQTTContext, &xTransport, prvGetTimeMs, prvEventCallback, &xBuffer );
    return xResult;
}

static void prvMQTTPublishToTopic( MQTTContext_t * pxMQTTContext )
{
    MQTTStatus_t xResult;
    MQTTPublishInfo_t xMQTTPublishInfo;

    /* Some fields are not used by this demo so start with everything at 0. */
    memset( (void * ) &xMQTTPublishInfo, 0x00, sizeof( xMQTTPublishInfo ) );

    /* This demo use QoS0. */
    xMQTTPublishInfo.qos = MQTTQoS1;
    xMQTTPublishInfo.retain = false;
    xMQTTPublishInfo.pTopicName = mqttexampleTOPIC;
    xMQTTPublishInfo.topicNameLength = ( uint16_t ) strlen( mqttexampleTOPIC );
    xMQTTPublishInfo.pPayload = mqttexampleMESSAGE;
    xMQTTPublishInfo.payloadLength = strlen( mqttexampleMESSAGE );

    /* Send PUBLISH packet. Packet ID is not used for a QoS0 publish. */
    xResult = MQTT_Publish( pxMQTTContext, &xMQTTPublishInfo, 0U );
    assert( xResult == MQTTSuccess );
}

/* Publish messages with Qos0, send and process keep alive messages. */
LogInfo( ( "Publish to the MQTT topic %s.", mqttexampeTOPIC ) );
prvMQTTPublishToTopic ( &xMQTTContext );

/* Process incoming publish echo, since application subscribed to the same
* topic the broker will send publish message back to the application. */
LogInfo( ( "Attempt to receive publish message from broker." ) );
xMQTTStatus = MQTT_ProcessLoop( &xMQTTContext, mqttexamplePROCESS_LOOP_TIMEOUT_MS );
assert( xMQTTStatus == MQTTSuccess );

static void prvMQTTAgentTask( void *pvParameters )
{
    for( ;; )
    {
        /* Wait with timeout for next command. */
        xCommand.xCommandType = NONE;
        xQueueReceive( xCommandQueue, &xCommand, exampleTICKS_TO_WAIT );

        switch( xCommand.xCommandType )
        {
            case PUBLISH:
                pxPublishInfo = xCommand.pxCmdContext->pxPublishInfo;
                MQTT_Publish( &globalMqttContext, pxPublishInfo, usPacketId );
                break;

            case /* Etc. for all other command types. */
        }

        MQTT_ProcessLoop( &globalMqttContext, 0 );
    }
}