diff --git a/lib/packet_mosq.c b/lib/packet_mosq.c index 686006fc..b1dc84f9 100644 --- a/lib/packet_mosq.c +++ b/lib/packet_mosq.c @@ -141,7 +141,7 @@ int packet__queue(struct mosquitto *mosq, struct mosquitto__packet *packet) #endif } - if(mosq->in_callback == false && mosq->threaded == false){ + if(mosq->in_callback == false && mosq->threaded == mosq_ts_none){ return packet__write(mosq); }else{ return MOSQ_ERR_SUCCESS;