MQTT version for enno SDK

Dependencies:   EthernetInterface MQTT mbed-rtos mbed serialzation_lib

Fork of HelloMQTT by MQTT

Committer:
weiarm2015
Date:
Wed Nov 25 07:07:31 2015 +0000
Revision:
20:3858e42b0cd3
Child:
21:c5f6350a292d
?

Who changed what in which revision?

UserRevisionLine numberNew 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 }