* ADD [quic] Example of how to set quic stream priority

Signed-off-by: Moi Ran <[email protected]>
nanomq · Nov 10, 2023 · 823f027 · 823f027
1 parent 67b114d
commit 823f027
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/mqtt/protocol/mqtt/mqtt_quic_client.c b/src/mqtt/protocol/mqtt/mqtt_quic_client.c
@@ -1749,6 +1749,12 @@ mqtt_quic_ctx_send(void *arg, nni_aio *aio)
 			if (pub_pipe == NULL) {
 				log_info("create new pub stream");
 				nni_lmq_put(s->topic_lmq, msg);
+				/*
+				 * You can set dialer quic priority before
+				 * dialer_start to create a stream with the
+				 * specified priority.
+				 */
+				//nni_dialer_setopt(npipe->p_dialer, NNG_OPT_MQTT_QUIC_PRIORITY, &val, sizeof(int), NNI_TYPE_INT32);
 				nni_dialer_start(npipe->p_dialer, NNG_FLAG_NONBLOCK);
 			} else {
 				if (mqtt_pipe_send_msg(aio, msg, pub_pipe, 0) >= 0) {