Paho Asynchronous MQTT C Client Library
Loading...
Searching...
No Matches
MQTTAsync.h
Go to the documentation of this file.
1/*******************************************************************************
2 * Copyright (c) 2009, 2021 IBM Corp., Ian Craggs and others
3 *
4 * All rights reserved. This program and the accompanying materials
5 * are made available under the terms of the Eclipse Public License v2.0
6 * and Eclipse Distribution License v1.0 which accompany this distribution.
7 *
8 * The Eclipse Public License is available at
9 * https://www.eclipse.org/legal/epl-2.0/
10 * and the Eclipse Distribution License is available at
11 * http://www.eclipse.org/org/documents/edl-v10.php.
12 *
13 * Contributors:
14 * Ian Craggs - initial API and implementation
15 * Ian Craggs, Allan Stockdill-Mander - SSL connections
16 * Ian Craggs - multiple server connection support
17 * Ian Craggs - MQTT 3.1.1 support
18 * Ian Craggs - fix for bug 444103 - success/failure callbacks not invoked
19 * Ian Craggs - automatic reconnect and offline buffering (send while disconnected)
20 * Ian Craggs - binary will message
21 * Ian Craggs - binary password
22 * Ian Craggs - remove const on eyecatchers #168
23 * Ian Craggs - MQTT 5.0
24 *******************************************************************************/
25
26/********************************************************************/
27
85/*
87*/
88#if !defined(MQTTASYNC_H)
89#define MQTTASYNC_H
90
91#if defined(__cplusplus)
92 extern "C" {
93#endif
94
95#include <stdio.h>
96/*
98*/
99
100#include "MQTTExportDeclarations.h"
101
102#include "MQTTProperties.h"
103#include "MQTTReasonCodes.h"
104#include "MQTTSubscribeOpts.h"
105#if !defined(NO_PERSISTENCE)
107#endif
108
113#define MQTTASYNC_SUCCESS 0
118#define MQTTASYNC_FAILURE -1
119
120/* error code -2 is MQTTAsync_PERSISTENCE_ERROR */
121
122#define MQTTASYNC_PERSISTENCE_ERROR -2
123
127#define MQTTASYNC_DISCONNECTED -3
132#define MQTTASYNC_MAX_MESSAGES_INFLIGHT -4
136#define MQTTASYNC_BAD_UTF8_STRING -5
140#define MQTTASYNC_NULL_PARAMETER -6
146#define MQTTASYNC_TOPICNAME_TRUNCATED -7
151#define MQTTASYNC_BAD_STRUCTURE -8
155#define MQTTASYNC_BAD_QOS -9
159#define MQTTASYNC_NO_MORE_MSGIDS -10
163#define MQTTASYNC_OPERATION_INCOMPLETE -11
167#define MQTTASYNC_MAX_BUFFERED_MESSAGES -12
171#define MQTTASYNC_SSL_NOT_SUPPORTED -13
177#define MQTTASYNC_BAD_PROTOCOL -14
181#define MQTTASYNC_BAD_MQTT_OPTION -15
185#define MQTTASYNC_WRONG_MQTT_VERSION -16
189#define MQTTASYNC_0_LEN_WILL_TOPIC -17
190/*
191 * Return code: connect or disconnect command ignored because there is already a connect or disconnect
192 * command at the head of the list waiting to be processed. Use the onSuccess/onFailure callbacks to wait
193 * for the previous connect or disconnect command to be complete.
194 */
195#define MQTTASYNC_COMMAND_IGNORED -18
199#define MQTTVERSION_DEFAULT 0
203#define MQTTVERSION_3_1 3
207#define MQTTVERSION_3_1_1 4
211#define MQTTVERSION_5 5
215#define MQTT_BAD_SUBSCRIBE 0x80
216
217
221typedef struct
222{
224 char struct_id[4];
230
231#define MQTTAsync_init_options_initializer { {'M', 'Q', 'T', 'G'}, 0, 0 }
232
238
243typedef void* MQTTAsync;
253typedef int MQTTAsync_token;
254
261typedef struct
262{
264 char struct_id[4];
271 void* payload;
285 int qos;
311 int dup;
317 int msgid;
323
324#define MQTTAsync_message_initializer { {'M', 'Q', 'T', 'M'}, 1, 0, NULL, 0, 0, 0, 0, MQTTProperties_initializer }
325
359typedef int MQTTAsync_messageArrived(void* context, char* topicName, int topicLen, MQTTAsync_message* message);
360
382typedef void MQTTAsync_deliveryComplete(void* context, MQTTAsync_token token);
383
402typedef void MQTTAsync_connectionLost(void* context, char* cause);
403
404
420typedef void MQTTAsync_connected(void* context, char* cause);
421
434typedef void MQTTAsync_disconnected(void* context, MQTTProperties* properties,
435 enum MQTTReasonCodes reasonCode);
436
452LIBMQTT_API int MQTTAsync_setDisconnected(MQTTAsync handle, void* context, MQTTAsync_disconnected* co);
453
455typedef struct
456{
458 char struct_id[4];
467 const char* username;
473 struct {
474 int len;
475 const void* data;
476 } binarypwd;
478
479#define MQTTAsync_connectData_initializer {{'M', 'Q', 'C', 'D'}, 0, NULL, {0, NULL}}
480
488
499
510
511
522
523
525typedef struct
526{
530 int code;
532 const char *message;
534
535
556
557#define MQTTAsync_failureData5_initializer {{'M', 'Q', 'F', 'D'}, 0, 0, MQTTREASONCODE_SUCCESS, MQTTProperties_initializer, 0, NULL, 0}
558
560typedef struct
561{
565 union
566 {
569 int qos;
574 struct
575 {
578 } pub;
579 /* For connect, the server connected to, MQTT version used, and sessionPresent flag */
580 struct
581 {
582 char* serverURI;
585 } connect;
586 } alt;
588
589
591typedef struct
592{
593 char struct_id[4];
600 union
601 {
603 struct
604 {
607 } sub;
609 struct
610 {
613 } pub;
614 /* For connect, the server connected to, MQTT version used, and sessionPresent flag */
615 struct
616 {
617 char* serverURI;
620 } connect;
622 struct
623 {
624 int reasonCodeCount;
625 enum MQTTReasonCodes* reasonCodes;
626 } unsub;
627 } alt;
629
630#define MQTTAsync_successData5_initializer {{'M', 'Q', 'S', 'D'}, 0, 0, MQTTREASONCODE_SUCCESS, MQTTProperties_initializer, {.sub={0,0}}}
631
645typedef void MQTTAsync_onSuccess(void* context, MQTTAsync_successData* response);
646
661typedef void MQTTAsync_onSuccess5(void* context, MQTTAsync_successData5* response);
662
676typedef void MQTTAsync_onFailure(void* context, MQTTAsync_failureData* response);
677
691typedef void MQTTAsync_onFailure5(void* context, MQTTAsync_failureData5* response);
692
699{
701 char struct_id[4];
722 void* context;
745 /*
746 * MQTT V5 subscribe options, when used with subscribe only.
747 */
749 /*
750 * MQTT V5 subscribe option count, when used with subscribeMany only.
751 * The number of entries in the subscribe_options_list array.
752 */
754 /*
755 * MQTT V5 subscribe option array, when used with subscribeMany only.
756 */
759
760#define MQTTAsync_responseOptions_initializer { {'M', 'Q', 'T', 'R'}, 1, NULL, NULL, 0, 0, NULL, NULL, MQTTProperties_initializer, MQTTSubscribe_options_initializer, 0, NULL}
761
764#define MQTTAsync_callOptions_initializer MQTTAsync_responseOptions_initializer
765
797
820
844
866
880
881
890LIBMQTT_API int MQTTAsync_reconnect(MQTTAsync handle);
891
892
937LIBMQTT_API int MQTTAsync_create(MQTTAsync* handle, const char* serverURI, const char* clientId,
938 int persistence_type, void* persistence_context);
939
941typedef struct
942{
944 char struct_id[4];
965 /*
966 * When the maximum number of buffered messages is reached, delete the oldest rather than the newest.
967 */
969 /*
970 * Restore messages from persistence on create - or clear it.
971 */
973 /*
974 * Persist QoS0 publish commands - an option to not persist them.
975 */
978
979#define MQTTAsync_createOptions_initializer { {'M', 'Q', 'C', 'O'}, 2, 0, 100, MQTTVERSION_DEFAULT, 0, 0, 1, 1}
980
981#define MQTTAsync_createOptions_initializer5 { {'M', 'Q', 'C', 'O'}, 2, 0, 100, MQTTVERSION_5, 0, 0, 1, 1}
982
983
984LIBMQTT_API int MQTTAsync_createWithOptions(MQTTAsync* handle, const char* serverURI, const char* clientId,
985 int persistence_type, void* persistence_context, MQTTAsync_createOptions* options);
986
999typedef struct
1000{
1002 char struct_id[4];
1008 const char* topicName;
1010 const char* message;
1019 int qos;
1021 struct
1022 {
1023 int len;
1024 const void* data;
1025 } payload;
1027
1028#define MQTTAsync_willOptions_initializer { {'M', 'Q', 'T', 'W'}, 1, NULL, NULL, 0, 0, { 0, NULL } }
1029
1030#define MQTT_SSL_VERSION_DEFAULT 0
1031#define MQTT_SSL_VERSION_TLS_1_0 1
1032#define MQTT_SSL_VERSION_TLS_1_1 2
1033#define MQTT_SSL_VERSION_TLS_1_2 3
1034
1047typedef struct
1048{
1050 char struct_id[4];
1051
1060
1062 const char* trustStore;
1063
1067 const char* keyStore;
1068
1072 const char* privateKey;
1073
1076
1086
1089
1095
1102
1108 const char* CApath;
1109
1114 int (*ssl_error_cb) (const char *str, size_t len, void *u);
1115
1121
1127 unsigned int (*ssl_psk_cb) (const char *hint, char *identity, unsigned int max_identity_len, unsigned char *psk, unsigned int max_psk_len, void *u);
1128
1134
1141
1149 const unsigned char *protos;
1150
1155 unsigned int protos_len;
1157
1158#define MQTTAsync_SSLOptions_initializer { {'M', 'Q', 'T', 'S'}, 5, NULL, NULL, NULL, NULL, NULL, 1, MQTT_SSL_VERSION_DEFAULT, 0, NULL, NULL, NULL, NULL, NULL, 0, NULL, 0 }
1159
1161typedef struct
1162{
1163 const char* name;
1164 const char* value;
1166
1356
1357
1358#define MQTTAsync_connectOptions_initializer { {'M', 'Q', 'T', 'C'}, 8, 60, 1, 65535, NULL, NULL, NULL, 30, 0,\
1359NULL, NULL, NULL, NULL, 0, NULL, MQTTVERSION_DEFAULT, 0, 1, 60, {0, NULL}, 0, NULL, NULL, NULL, NULL, NULL, NULL, NULL}
1360
1361#define MQTTAsync_connectOptions_initializer5 { {'M', 'Q', 'T', 'C'}, 8, 60, 0, 65535, NULL, NULL, NULL, 30, 0,\
1362NULL, NULL, NULL, NULL, 0, NULL, MQTTVERSION_5, 0, 1, 60, {0, NULL}, 1, NULL, NULL, NULL, NULL, NULL, NULL, NULL}
1363
1364#define MQTTAsync_connectOptions_initializer_ws { {'M', 'Q', 'T', 'C'}, 8, 45, 1, 65535, NULL, NULL, NULL, 30, 0,\
1365NULL, NULL, NULL, NULL, 0, NULL, MQTTVERSION_DEFAULT, 0, 1, 60, {0, NULL}, 0, NULL, NULL, NULL, NULL, NULL, NULL, NULL}
1366
1367#define MQTTAsync_connectOptions_initializer5_ws { {'M', 'Q', 'T', 'C'}, 8, 45, 0, 65535, NULL, NULL, NULL, 30, 0,\
1368NULL, NULL, NULL, NULL, 0, NULL, MQTTVERSION_5, 0, 1, 60, {0, NULL}, 1, NULL, NULL, NULL, NULL, NULL, NULL, NULL}
1369
1370
1391LIBMQTT_API int MQTTAsync_connect(MQTTAsync handle, const MQTTAsync_connectOptions* options);
1392
1444
1445#define MQTTAsync_disconnectOptions_initializer { {'M', 'Q', 'T', 'D'}, 0, 0, NULL, NULL, NULL,\
1446 MQTTProperties_initializer, MQTTREASONCODE_SUCCESS, NULL, NULL }
1447
1448#define MQTTAsync_disconnectOptions_initializer5 { {'M', 'Q', 'T', 'D'}, 1, 0, NULL, NULL, NULL,\
1449 MQTTProperties_initializer, MQTTREASONCODE_SUCCESS, NULL, NULL }
1450
1469LIBMQTT_API int MQTTAsync_disconnect(MQTTAsync handle, const MQTTAsync_disconnectOptions* options);
1470
1471
1479LIBMQTT_API int MQTTAsync_isConnected(MQTTAsync handle);
1480
1481
1496LIBMQTT_API int MQTTAsync_subscribe(MQTTAsync handle, const char* topic, int qos, MQTTAsync_responseOptions* response);
1497
1498
1516LIBMQTT_API int MQTTAsync_subscribeMany(MQTTAsync handle, int count, char* const* topic, const int* qos, MQTTAsync_responseOptions* response);
1517
1530LIBMQTT_API int MQTTAsync_unsubscribe(MQTTAsync handle, const char* topic, MQTTAsync_responseOptions* response);
1531
1544LIBMQTT_API int MQTTAsync_unsubscribeMany(MQTTAsync handle, int count, char* const* topic, MQTTAsync_responseOptions* response);
1545
1546
1566LIBMQTT_API int MQTTAsync_send(MQTTAsync handle, const char* destinationName, int payloadlen, const void* payload, int qos,
1567 int retained, MQTTAsync_responseOptions* response);
1568
1585LIBMQTT_API int MQTTAsync_sendMessage(MQTTAsync handle, const char* destinationName, const MQTTAsync_message* msg, MQTTAsync_responseOptions* response);
1586
1587
1606LIBMQTT_API int MQTTAsync_getPendingTokens(MQTTAsync handle, MQTTAsync_token **tokens);
1607
1616#define MQTTASYNC_TRUE 1
1617LIBMQTT_API int MQTTAsync_isComplete(MQTTAsync handle, MQTTAsync_token token);
1618
1619
1632LIBMQTT_API int MQTTAsync_waitForCompletion(MQTTAsync handle, MQTTAsync_token token, unsigned long timeout);
1633
1634
1646
1655LIBMQTT_API void MQTTAsync_free(void* ptr);
1656
1664LIBMQTT_API void* MQTTAsync_malloc(size_t size);
1665
1673LIBMQTT_API void MQTTAsync_destroy(MQTTAsync* handle);
1674
1675
1676
1687
1688
1695
1696
1705typedef void MQTTAsync_traceCallback(enum MQTTASYNC_TRACE_LEVELS level, char* message);
1706
1714
1722
1729LIBMQTT_API const char* MQTTAsync_strerror(int code);
1730
1731
2345#if defined(__cplusplus)
2346 }
2347#endif
2348
2349#endif
int MQTTAsync_connect(MQTTAsync handle, const MQTTAsync_connectOptions *options)
int MQTTAsync_unsubscribe(MQTTAsync handle, const char *topic, MQTTAsync_responseOptions *response)
void MQTTAsync_setTraceCallback(MQTTAsync_traceCallback *callback)
void * MQTTAsync
Definition MQTTAsync.h:243
int MQTTAsync_setBeforePersistenceWrite(MQTTAsync handle, void *context, MQTTPersistence_beforeWrite *co)
void MQTTAsync_global_init(MQTTAsync_init_options *inits)
int MQTTAsync_setConnected(MQTTAsync handle, void *context, MQTTAsync_connected *co)
void MQTTAsync_free(void *ptr)
void MQTTAsync_connected(void *context, char *cause)
Definition MQTTAsync.h:420
void MQTTAsync_connectionLost(void *context, char *cause)
Definition MQTTAsync.h:402
int MQTTAsync_messageArrived(void *context, char *topicName, int topicLen, MQTTAsync_message *message)
Definition MQTTAsync.h:359
int MQTTAsync_setMessageArrivedCallback(MQTTAsync handle, void *context, MQTTAsync_messageArrived *ma)
int MQTTAsync_isConnected(MQTTAsync handle)
int MQTTAsync_waitForCompletion(MQTTAsync handle, MQTTAsync_token token, unsigned long timeout)
void MQTTAsync_disconnected(void *context, MQTTProperties *properties, enum MQTTReasonCodes reasonCode)
Definition MQTTAsync.h:434
int MQTTAsync_create(MQTTAsync *handle, const char *serverURI, const char *clientId, int persistence_type, void *persistence_context)
int MQTTAsync_sendMessage(MQTTAsync handle, const char *destinationName, const MQTTAsync_message *msg, MQTTAsync_responseOptions *response)
MQTTAsync_nameValue * MQTTAsync_getVersionInfo(void)
MQTTASYNC_TRACE_LEVELS
Definition MQTTAsync.h:1678
@ MQTTASYNC_TRACE_FATAL
Definition MQTTAsync.h:1685
@ MQTTASYNC_TRACE_MEDIUM
Definition MQTTAsync.h:1680
@ MQTTASYNC_TRACE_SEVERE
Definition MQTTAsync.h:1684
@ MQTTASYNC_TRACE_PROTOCOL
Definition MQTTAsync.h:1682
@ MQTTASYNC_TRACE_MINIMUM
Definition MQTTAsync.h:1681
@ MQTTASYNC_TRACE_ERROR
Definition MQTTAsync.h:1683
@ MQTTASYNC_TRACE_MAXIMUM
Definition MQTTAsync.h:1679
int MQTTAsync_updateConnectOptions(void *context, MQTTAsync_connectData *data)
Definition MQTTAsync.h:487
void MQTTAsync_onFailure(void *context, MQTTAsync_failureData *response)
Definition MQTTAsync.h:676
int MQTTAsync_send(MQTTAsync handle, const char *destinationName, int payloadlen, const void *payload, int qos, int retained, MQTTAsync_responseOptions *response)
void MQTTAsync_traceCallback(enum MQTTASYNC_TRACE_LEVELS level, char *message)
Definition MQTTAsync.h:1705
int MQTTAsync_unsubscribeMany(MQTTAsync handle, int count, char *const *topic, MQTTAsync_responseOptions *response)
int MQTTAsync_createWithOptions(MQTTAsync *handle, const char *serverURI, const char *clientId, int persistence_type, void *persistence_context, MQTTAsync_createOptions *options)
void MQTTAsync_onSuccess(void *context, MQTTAsync_successData *response)
Definition MQTTAsync.h:645
int MQTTAsync_token
Definition MQTTAsync.h:253
const char * MQTTAsync_strerror(int code)
void MQTTAsync_onSuccess5(void *context, MQTTAsync_successData5 *response)
Definition MQTTAsync.h:661
void * MQTTAsync_malloc(size_t size)
void MQTTAsync_onFailure5(void *context, MQTTAsync_failureData5 *response)
Definition MQTTAsync.h:691
int MQTTAsync_setDeliveryCompleteCallback(MQTTAsync handle, void *context, MQTTAsync_deliveryComplete *dc)
void MQTTAsync_freeMessage(MQTTAsync_message **msg)
int MQTTAsync_setUpdateConnectOptions(MQTTAsync handle, void *context, MQTTAsync_updateConnectOptions *co)
void MQTTAsync_deliveryComplete(void *context, MQTTAsync_token token)
Definition MQTTAsync.h:382
int MQTTAsync_isComplete(MQTTAsync handle, MQTTAsync_token token)
int MQTTAsync_setAfterPersistenceRead(MQTTAsync handle, void *context, MQTTPersistence_afterRead *co)
int MQTTAsync_getPendingTokens(MQTTAsync handle, MQTTAsync_token **tokens)
int MQTTAsync_reconnect(MQTTAsync handle)
int MQTTAsync_subscribeMany(MQTTAsync handle, int count, char *const *topic, const int *qos, MQTTAsync_responseOptions *response)
void MQTTAsync_setTraceLevel(enum MQTTASYNC_TRACE_LEVELS level)
void MQTTAsync_destroy(MQTTAsync *handle)
int MQTTAsync_setDisconnected(MQTTAsync handle, void *context, MQTTAsync_disconnected *co)
int MQTTAsync_disconnect(MQTTAsync handle, const MQTTAsync_disconnectOptions *options)
int MQTTAsync_subscribe(MQTTAsync handle, const char *topic, int qos, MQTTAsync_responseOptions *response)
struct MQTTAsync_responseOptions MQTTAsync_responseOptions
int MQTTAsync_setCallbacks(MQTTAsync handle, void *context, MQTTAsync_connectionLost *cl, MQTTAsync_messageArrived *ma, MQTTAsync_deliveryComplete *dc)
int MQTTAsync_setConnectionLostCallback(MQTTAsync handle, void *context, MQTTAsync_connectionLost *cl)
This structure represents a persistent data store, used to store outbound and inbound messages,...
int MQTTPersistence_beforeWrite(void *context, int bufcount, char *buffers[], int buflens[])
Definition MQTTClientPersistence.h:264
int MQTTPersistence_afterRead(void *context, char **buffer, int *buflen)
Definition MQTTClientPersistence.h:275
MQTTReasonCodes
Definition MQTTReasonCodes.h:23
Definition MQTTAsync.h:1048
const char * trustStore
Definition MQTTAsync.h:1062
int struct_version
Definition MQTTAsync.h:1059
int disableDefaultTrustStore
Definition MQTTAsync.h:1140
void * ssl_error_context
Definition MQTTAsync.h:1120
unsigned int protos_len
Definition MQTTAsync.h:1155
const char * CApath
Definition MQTTAsync.h:1108
const char * keyStore
Definition MQTTAsync.h:1067
int sslVersion
Definition MQTTAsync.h:1094
const unsigned char * protos
Definition MQTTAsync.h:1149
int enableServerCertAuth
Definition MQTTAsync.h:1088
const char * privateKey
Definition MQTTAsync.h:1072
int verify
Definition MQTTAsync.h:1101
const char * enabledCipherSuites
Definition MQTTAsync.h:1085
void * ssl_psk_context
Definition MQTTAsync.h:1133
const char * privateKeyPassword
Definition MQTTAsync.h:1075
Definition MQTTAsync.h:456
int struct_version
Definition MQTTAsync.h:460
const void * data
Definition MQTTAsync.h:475
const char * username
Definition MQTTAsync.h:467
int len
Definition MQTTAsync.h:474
Definition MQTTAsync.h:1173
int maxRetryInterval
Definition MQTTAsync.h:1311
int cleansession
Definition MQTTAsync.h:1219
int struct_version
Definition MQTTAsync.h:1186
MQTTAsync_onFailure * onFailure
Definition MQTTAsync.h:1270
const void * data
Definition MQTTAsync.h:1317
int MQTTVersion
Definition MQTTAsync.h:1299
int minRetryInterval
Definition MQTTAsync.h:1307
MQTTAsync_onSuccess5 * onSuccess5
Definition MQTTAsync.h:1336
const char * httpsProxy
Definition MQTTAsync.h:1354
int connectTimeout
Definition MQTTAsync.h:1245
MQTTAsync_onFailure5 * onFailure5
Definition MQTTAsync.h:1342
int maxInflight
Definition MQTTAsync.h:1223
int automaticReconnect
Definition MQTTAsync.h:1303
MQTTAsync_willOptions * will
Definition MQTTAsync.h:1229
MQTTAsync_SSLOptions * ssl
Definition MQTTAsync.h:1258
MQTTProperties * connectProperties
Definition MQTTAsync.h:1326
const char * password
Definition MQTTAsync.h:1241
int serverURIcount
Definition MQTTAsync.h:1280
char *const * serverURIs
Definition MQTTAsync.h:1292
const char * username
Definition MQTTAsync.h:1235
MQTTAsync_onSuccess * onSuccess
Definition MQTTAsync.h:1264
MQTTProperties * willProperties
Definition MQTTAsync.h:1330
const MQTTAsync_nameValue * httpHeaders
Definition MQTTAsync.h:1346
int retryInterval
Definition MQTTAsync.h:1253
int keepAliveInterval
Definition MQTTAsync.h:1197
int cleanstart
Definition MQTTAsync.h:1322
const char * httpProxy
Definition MQTTAsync.h:1350
void * context
Definition MQTTAsync.h:1276
int len
Definition MQTTAsync.h:1316
Definition MQTTAsync.h:942
int struct_version
Definition MQTTAsync.h:950
int sendWhileDisconnected
Definition MQTTAsync.h:952
int persistQoS0
Definition MQTTAsync.h:976
int MQTTVersion
Definition MQTTAsync.h:960
int restoreMessages
Definition MQTTAsync.h:972
int maxBufferedMessages
Definition MQTTAsync.h:954
int deleteOldestMessages
Definition MQTTAsync.h:968
int allowDisconnectedSendAtAnyTime
Definition MQTTAsync.h:964
Definition MQTTAsync.h:1395
int struct_version
Definition MQTTAsync.h:1399
MQTTAsync_onFailure * onFailure
Definition MQTTAsync.h:1416
MQTTProperties properties
Definition MQTTAsync.h:1426
MQTTAsync_onSuccess5 * onSuccess5
Definition MQTTAsync.h:1436
int timeout
Definition MQTTAsync.h:1404
MQTTAsync_onFailure5 * onFailure5
Definition MQTTAsync.h:1442
enum MQTTReasonCodes reasonCode
Definition MQTTAsync.h:1430
MQTTAsync_onSuccess * onSuccess
Definition MQTTAsync.h:1410
void * context
Definition MQTTAsync.h:1422
Definition MQTTAsync.h:538
int struct_version
Definition MQTTAsync.h:542
MQTTProperties properties
Definition MQTTAsync.h:548
const char * message
Definition MQTTAsync.h:552
int packet_type
Definition MQTTAsync.h:554
int code
Definition MQTTAsync.h:550
enum MQTTReasonCodes reasonCode
Definition MQTTAsync.h:546
MQTTAsync_token token
Definition MQTTAsync.h:544
Definition MQTTAsync.h:526
const char * message
Definition MQTTAsync.h:532
int code
Definition MQTTAsync.h:530
MQTTAsync_token token
Definition MQTTAsync.h:528
Definition MQTTAsync.h:222
int struct_version
Definition MQTTAsync.h:226
int do_openssl_init
Definition MQTTAsync.h:228
Definition MQTTAsync.h:262
int struct_version
Definition MQTTAsync.h:267
MQTTProperties properties
Definition MQTTAsync.h:321
int qos
Definition MQTTAsync.h:285
int msgid
Definition MQTTAsync.h:317
int retained
Definition MQTTAsync.h:304
void * payload
Definition MQTTAsync.h:271
int payloadlen
Definition MQTTAsync.h:269
int dup
Definition MQTTAsync.h:311
Definition MQTTAsync.h:1162
const char * value
Definition MQTTAsync.h:1164
const char * name
Definition MQTTAsync.h:1163
Definition MQTTAsync.h:699
int struct_version
Definition MQTTAsync.h:704
MQTTAsync_onFailure * onFailure
Definition MQTTAsync.h:716
MQTTProperties properties
Definition MQTTAsync.h:744
MQTTSubscribe_options subscribeOptions
Definition MQTTAsync.h:748
int subscribeOptionsCount
Definition MQTTAsync.h:753
MQTTAsync_onSuccess5 * onSuccess5
Definition MQTTAsync.h:734
MQTTAsync_onFailure5 * onFailure5
Definition MQTTAsync.h:740
MQTTSubscribe_options * subscribeOptionsList
Definition MQTTAsync.h:757
char struct_id[4]
Definition MQTTAsync.h:701
MQTTAsync_onSuccess * onSuccess
Definition MQTTAsync.h:710
void * context
Definition MQTTAsync.h:722
MQTTAsync_token token
Definition MQTTAsync.h:728
Definition MQTTAsync.h:592
int struct_version
Definition MQTTAsync.h:594
int MQTTVersion
Definition MQTTAsync.h:618
MQTTProperties properties
Definition MQTTAsync.h:598
enum MQTTReasonCodes * reasonCodes
Definition MQTTAsync.h:606
int sessionPresent
Definition MQTTAsync.h:619
enum MQTTReasonCodes reasonCode
Definition MQTTAsync.h:597
MQTTAsync_message message
Definition MQTTAsync.h:611
char * serverURI
Definition MQTTAsync.h:617
int reasonCodeCount
Definition MQTTAsync.h:605
char * destinationName
Definition MQTTAsync.h:612
MQTTAsync_token token
Definition MQTTAsync.h:596
Definition MQTTAsync.h:561
int MQTTVersion
Definition MQTTAsync.h:583
int qos
Definition MQTTAsync.h:569
int sessionPresent
Definition MQTTAsync.h:584
MQTTAsync_message message
Definition MQTTAsync.h:576
int * qosList
Definition MQTTAsync.h:572
char * serverURI
Definition MQTTAsync.h:582
char * destinationName
Definition MQTTAsync.h:577
MQTTAsync_token token
Definition MQTTAsync.h:563
Definition MQTTAsync.h:1000
int struct_version
Definition MQTTAsync.h:1006
const void * data
Definition MQTTAsync.h:1024
const char * topicName
Definition MQTTAsync.h:1008
const char * message
Definition MQTTAsync.h:1010
int qos
Definition MQTTAsync.h:1019
int retained
Definition MQTTAsync.h:1014
int len
Definition MQTTAsync.h:1023
Definition MQTTProperties.h:113
Definition MQTTSubscribeOpts.h:22