m2mb_mqtt.h

Go to the documentation of this file.

/*===============================================================================================*/
/*         >>> Copyright (C) Telit Communications S.p.A. Italy All Rights Reserved. <<<          */
#ifndef  M2MB_MQTT_API_H
#define  M2MB_MQTT_API_H

/*-----------------------------------------------------------------------------------------------*/

#define M2MB_MQTT_MAX_SUBSCRIBE_HANDLERS         16     
typedef VOID *  M2MB_MQTT_CTXT_HANDLE;

typedef HANDLE M2MB_MQTT_CONN_PARAMS_HANDLE;

typedef VOID (*M2MB_MQTT_CONNECT_CB_T) (M2MB_MQTT_CTXT_HANDLE handle, INT32 status);
typedef VOID (*M2MB_MQTT_MSG_HNDLR_CB_T) (M2MB_MQTT_CTXT_HANDLE handle, void* arg, 
INT32 reason, const char* topic, UINT16 topic_Length, const char* msg, UINT32 msg_Length, UINT32 QOS );

/*---------------------------------------------------------------------------*/
INT32 m2mb_mqtt_con_params_create(M2MB_MQTT_CONN_PARAMS_HANDLE *connect_params, 
                const char *client_id, const char *host, long port, unsigned short keepalive_in_sec);
/*---------------------------------------------------------------------------*/
INT32 m2mb_mqtt_conn_params_set_username(M2MB_MQTT_CONN_PARAMS_HANDLE connect_params, 
        const char *username, const char *password);
/*---------------------------------------------------------------------------*/
M2MB_STATUS_T m2mb_mqtt_conn_params_set_timeout_in_sec(M2MB_MQTT_CONN_PARAMS_HANDLE connect_params, 
                                                                        unsigned short timeout_in_sec); 
/*---------------------------------------------------------------------------*/
M2MB_STATUS_T m2mb_mqtt_conn_params_set_ssl_cfg(M2MB_MQTT_CONN_PARAMS_HANDLE connect_params, 
                                                                        void* ssl_cfg) ;
/*---------------------------------------------------------------------------*/
M2MB_STATUS_T m2mb_mqtt_conn_params_set_connectCallback( M2MB_MQTT_CONN_PARAMS_HANDLE connect_params, 
                                                                        void *callback, void *callback_args);

/*---------------------------------------------------------------------------*/
M2MB_STATUS_T m2mb_mqtt_conn_params_use_ssl(M2MB_MQTT_CONN_PARAMS_HANDLE connect_params, char*ca_file, char* cert_file);

/*---------------------------------------------------------------------------*/
INT32 m2mb_mqtt_conn_params_delete(M2MB_MQTT_CONN_PARAMS_HANDLE connect_params);
/*---------------------------------------------------------------------------*/
INT32 m2mb_mqtt_connect(M2MB_MQTT_CTXT_HANDLE *mqtt_handle, M2MB_MQTT_CONN_PARAMS_HANDLE connect_params);
/*---------------------------------------------------------------------------*/
/*-----------------------------------------------------------------------------------------------*/
int m2mb_mqtt_disconnect(M2MB_MQTT_CTXT_HANDLE mqtt_handle);
int m2mb_mqtt_publish(M2MB_MQTT_CTXT_HANDLE mqtt_handle, int qos, int retain, unsigned short message_id, const char *topic, const char *data, int data_len);
int m2mb_mqtt_subscribe(M2MB_MQTT_CTXT_HANDLE mqtt_handle, unsigned short msg_id, const char *topic, int qos);
int m2mb_mqtt_unsubscribe(M2MB_MQTT_CTXT_HANDLE mqtt_handle, unsigned short msg_id, const char *topic);
INT32
m2mb_mqtt_subscribe_handler_register(M2MB_MQTT_CTXT_HANDLE mqtt_handle,
                                                                                                                        const char* topic, 
                                                                                                        M2MB_MQTT_MSG_HNDLR_CB_T cbk,
                                                                                                        VOID *arg);
/*-----------------------------------------------------------------------------------------------*/
#endif /*M2MB_MQTT_API_H*/