Building Smarter Planet Solutions with MQTT and IBM WebSphere MQ Telemetry

86 Building Smarter Planet Solutions with MQTT and IBM WebSphere MQ Telemetry

#include "string.h"

#include "MQTTClient.h"

#define ADDRESS "tcp://192.168.0.11:1883"

#define CLIENTID "Truck_00001_Pub"

#define TOPIC_Command "Truck/00001/Comm"

#define TOPIC_Temperature "Truck/00001/Temp"

#define QOS 2

#define TIMEOUT 10000L

volatile MQTTClient_deliveryToken deliveredtoken;

void delivered(void *context, MQTTClient_deliveryToken dt)

{

printf("Message with token value %d delivery confirmed\n", dt);

deliveredtoken = dt;

}

void connlost(void *context, char *cause)

{

printf("\nConnection lost\n");

printf(" cause: %s\n", cause);

}

int main(int argc, char* argv[])

{

MQTTClient client;

MQTTClient_connectOptions conn_opts;

MQTTClient_message pubmsg;

MQTTClient_deliv