![](/media/cache/img/default_profile.jpg.50x50_q85.jpg)
MQTT version for enno SDK
Dependencies: EthernetInterface MQTT mbed-rtos mbed serialzation_lib
Fork of HelloMQTT by
protocol/CplusplusToC.cpp@20:3858e42b0cd3, 2015-11-25 (annotated)
- Committer:
- weiarm2015
- Date:
- Wed Nov 25 07:07:31 2015 +0000
- Revision:
- 20:3858e42b0cd3
- Child:
- 21:c5f6350a292d
?
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
weiarm2015 | 20:3858e42b0cd3 | 1 | #include "MQTTClient.h" |
weiarm2015 | 20:3858e42b0cd3 | 2 | #include "stdio.h" |
weiarm2015 | 20:3858e42b0cd3 | 3 | |
weiarm2015 | 20:3858e42b0cd3 | 4 | static MQTTEthernet ipstack = MQTTEthernet(); |
weiarm2015 | 20:3858e42b0cd3 | 5 | static MQTT::Client<MQTTEthernet, Countdown> client = MQTT::Client<MQTTEthernet, Countdown>(ipstack); |
weiarm2015 | 20:3858e42b0cd3 | 6 | |
weiarm2015 | 20:3858e42b0cd3 | 7 | extern "C"{ |
weiarm2015 | 20:3858e42b0cd3 | 8 | int trans_connect(char *hostURL, uint16_t port, char *appKey); |
weiarm2015 | 20:3858e42b0cd3 | 9 | int trans_subscribe(); |
weiarm2015 | 20:3858e42b0cd3 | 10 | int trans_publish(); |
weiarm2015 | 20:3858e42b0cd3 | 11 | int trans_unsubscribe(char *pTopic); |
weiarm2015 | 20:3858e42b0cd3 | 12 | int trans_disconnect(); |
weiarm2015 | 20:3858e42b0cd3 | 13 | int trans_loop(int timeout); |
weiarm2015 | 20:3858e42b0cd3 | 14 | } |
weiarm2015 | 20:3858e42b0cd3 | 15 | |
weiarm2015 | 20:3858e42b0cd3 | 16 | int trans_connect(char *hostURL, uint16_t port, char *appKey){ |
weiarm2015 | 20:3858e42b0cd3 | 17 | int i = 0; |
weiarm2015 | 20:3858e42b0cd3 | 18 | |
weiarm2015 | 20:3858e42b0cd3 | 19 | return i; |
weiarm2015 | 20:3858e42b0cd3 | 20 | } |
weiarm2015 | 20:3858e42b0cd3 | 21 | int trans_subscribe(){ |
weiarm2015 | 20:3858e42b0cd3 | 22 | int i = 0; |
weiarm2015 | 20:3858e42b0cd3 | 23 | return i; |
weiarm2015 | 20:3858e42b0cd3 | 24 | } |
weiarm2015 | 20:3858e42b0cd3 | 25 | int trans_publish(){ |
weiarm2015 | 20:3858e42b0cd3 | 26 | int i = 0; |
weiarm2015 | 20:3858e42b0cd3 | 27 | return i; |
weiarm2015 | 20:3858e42b0cd3 | 28 | } |
weiarm2015 | 20:3858e42b0cd3 | 29 | int trans_unsubscribe(char *pTopic){ |
weiarm2015 | 20:3858e42b0cd3 | 30 | int i = 0; |
weiarm2015 | 20:3858e42b0cd3 | 31 | if ((i = client.unsubscribe(pTopic))!= 0){ |
weiarm2015 | 20:3858e42b0cd3 | 32 | printf("Error: unsubscribe fail %d\n", i); |
weiarm2015 | 20:3858e42b0cd3 | 33 | } |
weiarm2015 | 20:3858e42b0cd3 | 34 | return i; |
weiarm2015 | 20:3858e42b0cd3 | 35 | } |
weiarm2015 | 20:3858e42b0cd3 | 36 | int trans_disconnect(){ |
weiarm2015 | 20:3858e42b0cd3 | 37 | int i = 0; |
weiarm2015 | 20:3858e42b0cd3 | 38 | if ((i = client.disconnect()) != 0) |
weiarm2015 | 20:3858e42b0cd3 | 39 | printf("Error: disconnect fail %d\n", i); |
weiarm2015 | 20:3858e42b0cd3 | 40 | if(i ==0 ) { |
weiarm2015 | 20:3858e42b0cd3 | 41 | ipstack.disconnect(); |
weiarm2015 | 20:3858e42b0cd3 | 42 | } |
weiarm2015 | 20:3858e42b0cd3 | 43 | return i; |
weiarm2015 | 20:3858e42b0cd3 | 44 | } |
weiarm2015 | 20:3858e42b0cd3 | 45 | int trans_loop(int timeout){ |
weiarm2015 | 20:3858e42b0cd3 | 46 | int i = 0; |
weiarm2015 | 20:3858e42b0cd3 | 47 | i = client.yield(timeout); |
weiarm2015 | 20:3858e42b0cd3 | 48 | return i; |
weiarm2015 | 20:3858e42b0cd3 | 49 | } |