diff --git a/src/mqtt/protocol/mqtt/mqtt_quic_client.c b/src/mqtt/protocol/mqtt/mqtt_quic_client.c index 6f0ee2696..92d8be9d4 100644 --- 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) {