[MQTT] update handle name

Code clean, update param name - broker handle.

Signed-off-by: Jaeyun Jung <jy1210.jung@samsung.com>

diff --git a/src/libnnstreamer-edge/nnstreamer-edge-mqtt-mosquitto.c b/src/libnnstreamer-edge/nnstreamer-edge-mqtt-mosquitto.c
index b859a1c6f350213c2aec65cb861624335723c261..99c850dbabdd15ee109098809593d8ded06f64ea 100644 (file)
--- a/src/libnnstreamer-edge/nnstreamer-edge-mqtt-mosquitto.c
+++ b/src/libnnstreamer-edge/nnstreamer-edge-mqtt-mosquitto.c
@@ -258,7 +258,7 @@ nns_edge_mqtt_close (nns_edge_broker_h broker_h)
  * @brief Internal util function to send edge-data via MQTT connection.
  */
 int
-nns_edge_mqtt_publish_data (nns_edge_broker_h handle, nns_edge_data_h data_h)
+nns_edge_mqtt_publish_data (nns_edge_broker_h broker_h, nns_edge_data_h data_h)
 {
   int ret;
   void *data = NULL;
@@ -270,7 +270,7 @@ nns_edge_mqtt_publish_data (nns_edge_broker_h handle, nns_edge_data_h data_h)
     return ret;
   }
 
-  ret = nns_edge_mqtt_publish (handle, data, size);
+  ret = nns_edge_mqtt_publish (broker_h, data, size);
   if (NNS_EDGE_ERROR_NONE != ret)
     nns_edge_loge ("Failed to send data to destination.");
 

diff --git a/src/libnnstreamer-edge/nnstreamer-edge-mqtt-paho.c b/src/libnnstreamer-edge/nnstreamer-edge-mqtt-paho.c
index 658397d7fd07109ace453d0a9289e59e186b667b..651b09733347fec984ca82468d63bdf702e83870 100644 (file)
--- a/src/libnnstreamer-edge/nnstreamer-edge-mqtt-paho.c
+++ b/src/libnnstreamer-edge/nnstreamer-edge-mqtt-paho.c
@@ -268,7 +268,7 @@ nns_edge_mqtt_close (nns_edge_broker_h broker_h)
  * @brief Internal util function to send edge-data via MQTT connection.
  */
 int
-nns_edge_mqtt_publish_data (nns_edge_broker_h handle, nns_edge_data_h data_h)
+nns_edge_mqtt_publish_data (nns_edge_broker_h broker_h, nns_edge_data_h data_h)
 {
   int ret;
   void *data = NULL;
@@ -280,7 +280,7 @@ nns_edge_mqtt_publish_data (nns_edge_broker_h handle, nns_edge_data_h data_h)
     return ret;
   }
 
-  ret = nns_edge_mqtt_publish (handle, data, size);
+  ret = nns_edge_mqtt_publish (broker_h, data, size);
   if (NNS_EDGE_ERROR_NONE != ret)
     nns_edge_loge ("Failed to send data to destination.");
 

diff --git a/src/libnnstreamer-edge/nnstreamer-edge-mqtt.h b/src/libnnstreamer-edge/nnstreamer-edge-mqtt.h
index 7ef2532d9e325634ac77e06f7fff91e2637e4722..d1de9d655dde6905fd2416b3769c588b00bd9287 100644 (file)
--- a/src/libnnstreamer-edge/nnstreamer-edge-mqtt.h
+++ b/src/libnnstreamer-edge/nnstreamer-edge-mqtt.h
@@ -60,7 +60,7 @@ int nns_edge_mqtt_get_message (nns_edge_broker_h broker_h, void **msg, nns_size_
 /**
  * @brief Internal util function to send edge-data via MQTT connection.
  */
-int nns_edge_mqtt_publish_data (nns_edge_broker_h handle, nns_edge_data_h data_h);
+int nns_edge_mqtt_publish_data (nns_edge_broker_h broker_h, nns_edge_data_h data_h);
 
 /**
  * @brief Set event callback for new message.