[MQTTsink] remove message arrived cb

The callback `on_message_arrived ()` is not required for MQTTsink because it publishes the messages

Signed-off-by: Hyoung Joo Ahn <hello.ahn@samsung.com>

diff --git a/gst/mqtt/mqttsink.c b/gst/mqtt/mqttsink.c
index 7465728..ccca029 100644 (file)
--- a/gst/mqtt/mqttsink.c
+++ b/gst/mqtt/mqttsink.c
@@ -141,8 +141,6 @@ static void cb_mqtt_on_disconnect_failure (void *context,
     MQTTAsync_failureData * response);
 static void cb_mqtt_on_delivery_complete (void *context, MQTTAsync_token token);
 static void cb_mqtt_on_connection_lost (void *context, char *cause);
-static int cb_mqtt_on_message_arrived (void *context, char *topicName,
-    int topicLen, MQTTAsync_message * message);
 static void cb_mqtt_on_send_success (void *context,
     MQTTAsync_successData * response);
 static void cb_mqtt_on_send_failure (void *context,
@@ -525,8 +523,7 @@ gst_mqtt_sink_start (GstBaseSink * basesink)
     return FALSE;
 
   MQTTAsync_setCallbacks (self->mqtt_client_handle, self,
-      cb_mqtt_on_connection_lost, cb_mqtt_on_message_arrived,
-      cb_mqtt_on_delivery_complete);
+      cb_mqtt_on_connection_lost, NULL, cb_mqtt_on_delivery_complete);
 
   ret = MQTTAsync_connect (self->mqtt_client_handle, &self->mqtt_conn_opts);
   if (ret != MQTTASYNC_SUCCESS) {
@@ -1158,17 +1155,6 @@ cb_mqtt_on_connection_lost (void *context, char *cause)
 }
 
 /**
- * @brief A callback function to be given to the MQTTAsync_setCallbacks funtion.
- *        In the case of the publisher, this callbase is not used.
- */
-static int
-cb_mqtt_on_message_arrived (void *context, char *topicName, int topicLen,
-    MQTTAsync_message * message)
-{
-  return 1;
-}
-
-/**
  * @brief A callback function corresponding to MQTTAsync_responseOptions's
  *        onSuccess.
  */