eclipse-paho / eclipse-paho/paho.mqtt.java

Too many publishes is in progress with QOS 1

Open
#551 21 comments 1 reaction 1 assignee Claimed by @jpwsutton View on GitHub
question
Dominant language
Java
Stars
2.3k
Forks
919
PR merge metrics
No merged PRs in 30d

Description

Hi All,
i set to maxInflight messages property to 1000 and trying to publish messages with 300 TPS, But after some point(after submiting 55K message) i'm facing below issue.

MqttException (0) - Too many publishes in progress (32202)
at com.imi.rtm.manager.PahoAsyncConnectionManager.publishMessage(PahoAsyncConnectionManager.java:205)
at com.imi.rtm.manager.RTMDispatcher.processInternal(RTMDispatcher.java:343)
at com.imi.rtm.manager.RTMDispatcher.process(RTMDispatcher.java:399)
at com.imi.rtm.manager.RTMProcessManager.processMessage(RTMProcessManager.java:619)
at com.imi.rtm.manager.RTMProcessManager.process(RTMProcessManager.java:241)
at com.imi.rtm.main.RTMProcessor$1.process(RTMProcessor.java:152)
at com.imimobile.ump.queue.processor.AbstractProcessor$1.run(AbstractProcessor.java:339)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: Too many publishes in progress (32202)
at org.eclipse.paho.client.mqttv3.internal.ClientState.send(ClientState.java:513)
at org.eclipse.paho.client.mqttv3.internal.ClientComms.internalSend(ClientComms.java:158)
at org.eclipse.paho.client.mqttv3.internal.ClientComms.sendNoWait(ClientComms.java:187)
at org.eclipse.paho.client.mqttv3.MqttAsyncClient.publish(MqttAsyncClient.java:1355)
at com.imi.rtm.manager.PahoAsyncConnectionManager.publishMessage(PahoAsyncConnectionManager.java:203)
... 11 more

Can anyone suggest me what to do.
Im using mosca server as backend and Java client as org.eclipse.paho.client.mqttv3-1.2.0 version.

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.