Inflight queue max size

535 views
Skip to first unread message

Paolo Patierno

unread,
May 6, 2014, 2:13:51 AM5/6/14
to mq...@googlegroups.com
Hello,
there is a question about inflight queue that the 3.1.1 specification doesn't clarify well.
If we set a max size for the inflight queue and during normal operation the queue becomes full on the client, if the client try to put a new message on the inflight queue...what does it happen ?
The message is dropped (so it won't be published) or the function to put in the queue will wait until a position inside the queue will be free ?

Paolo.


Dave Locke

unread,
May 6, 2014, 4:32:34 AM5/6/14
to mq...@googlegroups.com
Hi,
if the OASIS spec is not clear please raise comments against the spec at OASIS.  It is important the spec is as clear as possible for future generations and until the spec is finalised it can be improved.

Specifically to your question, the spec talks about the protocol i.e.  what flows over the wire but does not describe the programming interface.  Whether the programming interface blocks when an inflgiht window is full or rejects the request is down to the implementation of the mqtt client library.  


All the best
Dave

--
To learn more about MQTT please visit
http://mqtt.org
---
You received this message because you are subscribed to the Google Groups "MQTT" group.
To unsubscribe from this group and stop receiving emails from it, send an email to
mqtt+uns...@googlegroups.com.
To post to this group, send email to
mq...@googlegroups.com.
Visit this group at
http://groups.google.com/group/mqtt.
For more options, visit
https://groups.google.com/d/optout.

Unless stated otherwise above:
IBM United Kingdom Limited - Registered in England and Wales with number 741598.
Registered office: PO Box 41, North Harbour, Portsmouth, Hampshire PO6 3AU

Paolo Patierno

unread,
May 6, 2014, 4:38:06 AM5/6/14
to mq...@googlegroups.com
Thanks Dave,
you clarified me that the spec isn't clear because my question is strictly related to client implementation and not to the standard.


Paolo.


Il giorno martedì 6 maggio 2014 10:32:34 UTC+2, Dave Locke ha scritto:
Hi,
if the OASIS spec is not clear please raise comments against the spec at OASIS.  It is important the spec is as clear as possible for future generations and until the spec is finalised it can be improved.

Specifically to your question, the spec talks about the protocol i.e.  what flows over the wire but does not describe the programming interface.  Whether the programming interface blocks when an inflgiht window is full or rejects the request is down to the implementation of the mqtt client library.  


All the best
Dave




From:        Paolo Patierno <paolo.p...@gmail.com>
To:        mq...@googlegroups.com
Date:        06/05/2014 07:14
Subject:        [mqtt] Inflight queue max size
Sent by:        mq...@googlegroups.com




Hello,
there is a question about inflight queue that the 3.1.1 specification doesn't clarify well.
If we set a max size for the inflight queue and during normal operation the queue becomes full on the client, if the client try to put a new message on the inflight queue...what does it happen ?
The message is dropped (so it won't be published) or the function to put in the queue will wait until a position inside the queue will be free ?

Paolo.

--
To learn more about MQTT please visit
http://mqtt.org


---
You received this message because you are subscribed to the Google Groups "MQTT" group.

To unsubscribe from this group and stop receiving emails from it, send an email to mqtt+unsubscribe@googlegroups.com.


To post to this group, send email to

rama naidu

unread,
Oct 11, 2014, 8:14:52 AM10/11/14
to mq...@googlegroups.com
Hello,

Can you please clarify me how to increase the inflight messages in mosquitto broker and queue size so that no message should be dropped.

Thanks,
Ram

Roger Light

unread,
Oct 11, 2014, 4:44:44 PM10/11/14
to mq...@googlegroups.com
Hi Ram,

Set max_inflight_messages and max_queued_messages to 0.

Cheers,

Roger
> --
> To learn more about MQTT please visit http://mqtt.org
> ---
> You received this message because you are subscribed to the Google Groups
> "MQTT" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to mqtt+uns...@googlegroups.com.

rama naidu

unread,
Oct 13, 2014, 12:22:30 AM10/13/14
to mq...@googlegroups.com, ro...@atchoo.org
Hello Roger..!!

Thanks for your quick reply.
It didn't work for me even I set both values to 0 in the mosquitto.config.
I am getting only 20 messages if the other end device is in offline.

Could you please help me out in this if i required to change any modifications in the config file.

Thanks Inadance
Ram.
Reply all
Reply to author
Forward
0 new messages