Guilhem Saurel
/
niMQTT_example
An exemple for the lib niMQTT
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?
User | Revision | Line number | New 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 | } |