Skip to main content

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [List Home]
Re: [paho-dev] Question about maximum in flight messages

Hi Herman,

I think maxInFlight can be added to MqttConnectOptions, and it should be very straightforward to implement.
and i will take at the bug you've filed.

Best Regards,
Bin Zhang
--------------------------------------------------------------------------------------------
WebSphere MQ, IBM China Software Development Lab
Notes:   Bin BJ Zhang/China/IBM
E-Mail:  zhbinbj@xxxxxxxxxx
Address: Ring Building 3F, ZhongGuanCun Software Park,

DongBeiWang West Road No.8, Haidian District, Beijing, 100193, China
-------------------------------------------------------------------------------------------


Inactive hide details for Herman ---01/06/2015 05:33:13 AM---Hi Ian and everyone on the list, Firstly, Happy New Year!Herman ---01/06/2015 05:33:13 AM---Hi Ian and everyone on the list, Firstly, Happy New Year!

From: Herman <ssjherman@xxxxxxxxx>
To: General development discussions for paho project <paho-dev@xxxxxxxxxxx>
Date: 01/06/2015 05:33 AM
Subject: Re: [paho-dev] Question about maximum in flight messages
Sent by: paho-dev-bounces@xxxxxxxxxxx





Hi Ian and everyone on the list,

Firstly, Happy New Year!

Now on to questions.., Ian you mentioned: One option would be to make this value an option which could be set, and which defaults to 10 (regarding the maxInFlight var). Could we put this in the pipeline of changes in store for the Mqtt Java Client lib, and if so do you have an approximate date/month/year when this may be implemented?

Another issue we are currently having is described in this bug report, if anyone could take a look: https://bugs.eclipse.org/bugs/show_bug.cgi?id=456719 

Thank you for the help,
Herman

On Mon, Dec 22, 2014 at 10:51 AM, Ian Craggs <icraggs@xxxxxxxxxxxxxxxxxxxxxxx> wrote:
    Hi Herman,

    the limit is not higher in newer versions.  One option would be to make this value an option which could be set, and which defaults to 10.  Any change would be made to the latest version -- 1.0, not 0.4.

    Ian




    On 12/17/2014 05:19 PM, Herman wrote:
      Thanks for your answer about message persistence Dave - it's exactly what I was looking for!

      I had another question about the limits to how many messages we can send without receiving acknowledgements, I noticed that in the version of the Java Paho Client we're using (0.4.0), in ClientState.java "maxInflight" is set to 10, above which this exception is thrown: Too many publishes in progress Reason code: 32202

      One of our use cases for the client involves a very high level load of messages being sent, and we regularly hit this limit. What is the best way to get around it? Should we create multiple MqttAsyncClient instances and load balance across them? Do you have any other suggestions? For example: is this limit higher in updated versions (like 1.0)?

      Thank you for the help!
      Herman


      _______________________________________________
      paho-dev mailing list
      paho-dev@xxxxxxxxxxx
      To change your delivery options, retrieve your password, or unsubscribe from this list, visit
      https://dev.eclipse.org/mailman/listinfo/paho-dev

    --
    Ian Craggs                          
    icraggs@xxxxxxxxxx                 IBM United Kingdom
    Paho Project Lead; Committer on Mosquitto



    _______________________________________________
    paho-dev mailing list

    paho-dev@xxxxxxxxxxx
    To change your delivery options, retrieve your password, or unsubscribe from this list, visit

    https://dev.eclipse.org/mailman/listinfo/paho-dev
_______________________________________________
paho-dev mailing list
paho-dev@xxxxxxxxxxx
To change your delivery options, retrieve your password, or unsubscribe from this list, visit
https://dev.eclipse.org/mailman/listinfo/paho-dev

GIF image


Back to the top