* NEW [mqtt/include] add 2 macros to define max length of send/recv_…

…queue
emqx · Feb 3, 2022 · fd1bb3f · fd1bb3f
1 parent 7e08e82
commit fd1bb3f
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/include/nng/mqtt/mqtt_client.h b/include/nng/mqtt/mqtt_client.h
@@ -121,6 +121,12 @@ extern "C" {
 #define NNG_OPT_MQTT_TOPIC_ALIAS "topic-alias"
 #define NNG_OPT_MQTT_MAX_QOS "max-qos"
 
+// NNG_MAX_RECV_LMQ and NNG_MAX_SEND_LMQ define the length of waiting queue
+// they are the length of nni_lmq, please be ware it affects the memory usage
+// significantly while having heavy throughput
+#define NNG_MAX_RECV_LMQ 16
+#define NNG_MAX_SEND_LMQ 16
+
 // NNG_TLS_xxx options can be set on the client as well.
 // E.g. NNG_OPT_TLS_CA_CERT, etc.