eclipse-paho / eclipse-paho/paho.mqtt.java
Too many publishes is in progress with QOS 1
- 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
Assessment
This issue has not been assessed yet.