File content as of revision 0:a655fd59ed71:

#include "PubSubClient.h"

void PubSubClient::init()
{
    static TCPSocket socket1;
    socket=&socket1;
    static MQTTClient client1(&socket1);
    client=&client1;
    static ESP8266Interface esp1(MBED_CONF_APP_ESP_TX_PIN, MBED_CONF_APP_ESP_RX_PIN);
    esp=&esp1;
    int ret = esp->connect(MBED_CONF_APP_WIFI_SSID, MBED_CONF_APP_WIFI_PASSWORD, NSAPI_SECURITY_WPA_WPA2);

    if(ret != 0)
    {
        printf("\nConnection error\n");
    }
    else
    {
        printf("\nConnection success\n");
    }
    esp->get_ip_address(&deviceIP);
    printf("IP via DHCP: %s\n", deviceIP.get_ip_address());
    
    // Use with IP
    //SocketAddress MQTTBroker(MBED_CONF_APP_MQTT_BROKER_IP, MBED_CONF_APP_MQTT_BROKER_PORT);
    
    // Use with DNS
    esp->gethostbyname(MBED_CONF_APP_MQTT_BROKER_HOSTNAME, &MQTTBroker);
    
    printf("\nMQTTBroker %s\n",MQTTBroker.get_ip_address());
    MQTTBroker.set_port(MBED_CONF_APP_MQTT_BROKER_PORT);
    
    msg.qos = MQTT::QOS0;
    msg.retained = false;
    msg.dup = false;
    
    printf("\n socket open: %d\n",socket->open(esp));
    printf("\n socket connect: %d\n",socket->connect(MQTTBroker));
}

PubSubClient::PubSubClient()
{
    init();
}

bool PubSubClient::connect(char* clientName)
{
    int ret=0;
    MQTTPacket_connectData data = MQTTPacket_connectData_initializer;  
        
    data.MQTTVersion = 3;
    char *id = clientName;//MBED_CONF_APP_MQTT_ID;
    
    data.clientID.cstring=id;
    
    printf("\n ID=%s\n",clientName);
    
    ret=client->connect(data);
    printf("\n client connect: %d\n",ret);
    
    return ret==0;
}

int PubSubClient::publish(const char* topic, const char* buf)
{
        msg.payload = (void*)buf;
        msg.payloadlen = strlen(buf);
        int ret=client->publish(topic, msg);
        return ret;
}