MQTT version for enno SDK
Dependencies: EthernetInterface MQTT mbed-rtos mbed serialzation_lib
Fork of HelloMQTT by
Diff: protocol/CplusplusToC.cpp
- Revision:
- 20:3858e42b0cd3
- Child:
- 21:c5f6350a292d
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/protocol/CplusplusToC.cpp Wed Nov 25 07:07:31 2015 +0000 @@ -0,0 +1,49 @@ +#include "MQTTClient.h" +#include "stdio.h" + +static MQTTEthernet ipstack = MQTTEthernet(); +static MQTT::Client<MQTTEthernet, Countdown> client = MQTT::Client<MQTTEthernet, Countdown>(ipstack); + +extern "C"{ + int trans_connect(char *hostURL, uint16_t port, char *appKey); + int trans_subscribe(); + int trans_publish(); + int trans_unsubscribe(char *pTopic); + int trans_disconnect(); + int trans_loop(int timeout); +} + + int trans_connect(char *hostURL, uint16_t port, char *appKey){ + int i = 0; + + return i; +} +int trans_subscribe(){ + int i = 0; + return i; +} +int trans_publish(){ + int i = 0; + return i; +} +int trans_unsubscribe(char *pTopic){ + int i = 0; + if ((i = client.unsubscribe(pTopic))!= 0){ + printf("Error: unsubscribe fail %d\n", i); + } + return i; +} +int trans_disconnect(){ + int i = 0; + if ((i = client.disconnect()) != 0) + printf("Error: disconnect fail %d\n", i); + if(i ==0 ) { + ipstack.disconnect(); + } + return i; +} +int trans_loop(int timeout){ + int i = 0; + i = client.yield(timeout); + return i; +} \ No newline at end of file