Function startMqttClient

samples/MqttClient_Hello/app/application.cpp:70–108

Run MQTT client

// Run MQTT client
void startMqttClient()
{
	procTimer.stop();

	// 1. [Setup]
	if(!mqtt.setWill(F("last/will"), F("The connection from this device is lost:("),
					 MqttClient::getFlags(MQTT_QOS_AT_LEAST_ONCE, MQTT_RETAIN_TRUE))) {
		debugf("Unable to set the last will and testament. Most probably there is not enough memory on the device.");
	}

	mqtt.setEventHandler(MQTT_TYPE_PUBACK, onMessageDelivered);

	mqtt.setConnectedHandler([](MqttClient& client, mqtt_message_t* message) {
		Serial << _F("Connected to ") << client.getRemoteIp() << endl;

		// Start publishing message now
		publishMessage();
		// and schedule a timer to send messages every 5 seconds
		procTimer.initializeMs<5 * 1000>(publishMessage).start();
		return 0;
	});

	mqtt.setCompleteDelegate(checkMQTTDisconnect);
	mqtt.setMessageHandler(onMessageReceived);

#ifdef ENABLE_SSL
	mqtt.setSslInitHandler([](Ssl::Session& session) {
		session.options.verifyLater = true;
		session.keyCert.assign(default_private_key, sizeof(default_private_key), default_certificate,
							   sizeof(default_certificate), nullptr);
	});
#endif

	// 2. [Connect]
	Url url(MQTT_URL);
	Serial << _F("Connecting to ") << url << endl;
	mqtt.connect(url, F("esp8266"));
	mqtt.subscribe(F("main/status/#"));
}

void onConnected(IpAddress ip, IpAddress netmask, IpAddress gateway)
{