{"action":"opened","issue":{"url":"https://api.github.com/repos/eclipse/paho.mqtt.java/issues/551","repository_url":"https://api.github.com/repos/eclipse/paho.mqtt.java","labels_url":"https://api.github.com/repos/eclipse/paho.mqtt.java/issues/551/labels{/name}","comments_url":"https://api.github.com/repos/eclipse/paho.mqtt.java/issues/551/comments","events_url":"https://api.github.com/repos/eclipse/paho.mqtt.java/issues/551/events","html_url":"https://github.com/eclipse/paho.mqtt.java/issues/551","id":329420345,"node_id":"MDU6SXNzdWUzMjk0MjAzNDU=","number":551,"title":"Too many publishes is in progress with QOS 1","user":{"login":"sunny1974","id":18138616,"node_id":"MDQ6VXNlcjE4MTM4NjE2","avatar_url":"https://avatars3.githubusercontent.com/u/18138616?v=4","gravatar_id":"","url":"https://api.github.com/users/sunny1974","html_url":"https://github.com/sunny1974","followers_url":"https://api.github.com/users/sunny1974/followers","following_url":"https://api.github.com/users/sunny1974/following{/other_user}","gists_url":"https://api.github.com/users/sunny1974/gists{/gist_id}","starred_url":"https://api.github.com/users/sunny1974/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/sunny1974/subscriptions","organizations_url":"https://api.github.com/users/sunny1974/orgs","repos_url":"https://api.github.com/users/sunny1974/repos","events_url":"https://api.github.com/users/sunny1974/events{/privacy}","received_events_url":"https://api.github.com/users/sunny1974/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":0,"created_at":"2018-06-05T11:48:29Z","updated_at":"2018-06-05T11:48:29Z","closed_at":null,"author_association":"NONE","body":"Hi All,\r\ni 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.\r\n\r\nMqttException (0) - Too many publishes in progress (32202)\r\n        at com.imi.rtm.manager.PahoAsyncConnectionManager.publishMessage(PahoAsyncConnectionManager.java:205)\r\n        at com.imi.rtm.manager.RTMDispatcher.processInternal(RTMDispatcher.java:343)\r\n        at com.imi.rtm.manager.RTMDispatcher.process(RTMDispatcher.java:399)\r\n        at com.imi.rtm.manager.RTMProcessManager.processMessage(RTMProcessManager.java:619)\r\n        at com.imi.rtm.manager.RTMProcessManager.process(RTMProcessManager.java:241)\r\n        at com.imi.rtm.main.RTMProcessor$1.process(RTMProcessor.java:152)\r\n        at com.imimobile.ump.queue.processor.AbstractProcessor$1.run(AbstractProcessor.java:339)\r\n        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\r\n        at java.util.concurrent.FutureTask.run(FutureTask.java:266)\r\n        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)\r\n        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)\r\n        at java.lang.Thread.run(Thread.java:745)\r\nCaused by: Too many publishes in progress (32202)\r\n        at org.eclipse.paho.client.mqttv3.internal.ClientState.send(ClientState.java:513)\r\n        at org.eclipse.paho.client.mqttv3.internal.ClientComms.internalSend(ClientComms.java:158)\r\n        at org.eclipse.paho.client.mqttv3.internal.ClientComms.sendNoWait(ClientComms.java:187)\r\n        at org.eclipse.paho.client.mqttv3.MqttAsyncClient.publish(MqttAsyncClient.java:1355)\r\n        at com.imi.rtm.manager.PahoAsyncConnectionManager.publishMessage(PahoAsyncConnectionManager.java:203)\r\n        ... 11 more\r\n\r\nCan anyone suggest me what to do.\r\nIm using mosca server as backend and Java client as org.eclipse.paho.client.mqttv3-1.2.0 version."}}
{"actor":{"display_login":"sunny1974"}}