Guilhem Saurel / Mbed 2 deprecated niMQTT_example

An exemple for the lib niMQTT

Dependencies:   niMQTT mbed

main.cpp@2:d42e14112adf, 2013-08-13 (annotated)

Committer:
Nim65s
Date:
Tue Aug 13 13:44:23 2013 +0000
Revision:
2:d42e14112adf
Parent:
0:db40c618e10c 
updated niMQTT version

Who changed what in which revision?

UserRevisionLine numberNew contents of line
Nim65s 0:db40c618e10c 1 #include "mbed.h"
Nim65s 0:db40c618e10c 2 #include "rtos.h"
Nim65s 0:db40c618e10c 3 #include "niMQTT.h"
Nim65s 0:db40c618e10c 4 #include "EthernetInterface.h"
Nim65s 0:db40c618e10c 5
Nim65s 0:db40c618e10c 6 EthernetInterface eth;
Nim65s 0:db40c618e10c 7
Nim65s 0:db40c618e10c 8 DigitalOut led(LED1);
Nim65s 0:db40c618e10c 9 DigitalIn pub(p14);
Nim65s 0:db40c618e10c 10
Nim65s 2:d42e14112adf 11 void callback(const char *topic, const char *message) {
Nim65s 0:db40c618e10c 12 printf("==== New PUBLISH received ====\r\n");
Nim65s 0:db40c618e10c 13 printf(topic);
Nim65s 0:db40c618e10c 14 printf("\r\n------------------------------\r\n");
Nim65s 0:db40c618e10c 15 printf(message);
Nim65s 0:db40c618e10c 16 printf("\r\n------------ end -------------\r\n");
Nim65s 0:db40c618e10c 17 }
Nim65s 0:db40c618e10c 18
Nim65s 0:db40c618e10c 19 int main() {
Nim65s 0:db40c618e10c 20 printf("\r\n====================================================\r\n");
Nim65s 0:db40c618e10c 21 eth.init();
Nim65s 0:db40c618e10c 22 do printf("Connection...\r\n"); while (eth.connect() != 0);
Nim65s 0:db40c618e10c 23
Nim65s 0:db40c618e10c 24 niMQTT client("10.41.51.53", callback);
Nim65s 0:db40c618e10c 25
Nim65s 0:db40c618e10c 26 client.pub("mbed", "Hello World");
Nim65s 0:db40c618e10c 27
Nim65s 0:db40c618e10c 28 client.sub("mbed", false);
Nim65s 0:db40c618e10c 29
Nim65s 0:db40c618e10c 30 while(true) {
Nim65s 0:db40c618e10c 31 if (pub) client.pub("mbed", "test");
Nim65s 0:db40c618e10c 32 led = 0;
Nim65s 0:db40c618e10c 33 wait(1);
Nim65s 0:db40c618e10c 34 led = 1;
Nim65s 0:db40c618e10c 35 wait(1);
Nim65s 0:db40c618e10c 36 }
Nim65s 0:db40c618e10c 37 }