|
@@ -594,7 +594,7 @@ int mqtt_prepare_publish(str *topic, str *payload, int qos)
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
- *
|
|
|
+ *
|
|
|
*/
|
|
|
void mqtt_request_notify(
|
|
|
struct ev_loop *loop, struct ev_io *watcher, int revents)
|
|
@@ -636,7 +636,7 @@ void mqtt_request_notify(
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
- *
|
|
|
+ *
|
|
|
*/
|
|
|
int mqtt_publish(str *topic, str *payload, int qos)
|
|
|
{
|
|
@@ -655,7 +655,7 @@ int mqtt_publish(str *topic, str *payload, int qos)
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
- *
|
|
|
+ *
|
|
|
*/
|
|
|
int mqtt_prepare_subscribe(str *topic, int qos)
|
|
|
{
|
|
@@ -706,7 +706,7 @@ int mqtt_prepare_subscribe(str *topic, int qos)
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
- *
|
|
|
+ *
|
|
|
*/
|
|
|
int mqtt_subscribe(str *topic, int qos)
|
|
|
{
|
|
@@ -722,7 +722,7 @@ int mqtt_subscribe(str *topic, int qos)
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
- *
|
|
|
+ *
|
|
|
*/
|
|
|
int mqtt_prepare_unsubscribe(str *topic)
|
|
|
{
|
|
@@ -769,7 +769,7 @@ int mqtt_prepare_unsubscribe(str *topic)
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
- *
|
|
|
+ *
|
|
|
*/
|
|
|
int mqtt_unsubscribe(str *topic)
|
|
|
{
|