
50 Building Smarter Planet Solutions with MQTT and IBM WebSphere MQ Telemetry
#include "MQTTClient.h"
#include "callback.h
#define ADDRESS "tcp://localhost:1883"
#define CLIENTID "Truck01"
#define TOPIC "commands/Truck01"
#define QOS 1
int main(int argc, char* argv[])
{
MQTTClient client;
MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
int rc;
int ch;
//a. Create an instance of MQTT client
MQTTClient_create(&client, ADDRESS, CLIENTID,
MQTTCLIENT_PERSISTENCE_NONE, NULL);
//b. Prepare connection options
conn_opts.keepAliveInterval = 20;
conn_opts.cleansession = 1;
MQTTClient_setCallbacks(client, NULL, connlost, msgarrvd, ...