Allow more simultaneous MQTT publishments

[schneiti]

If the MBP performs many publishments within a short period of time a MQTT exception is thrown which prevents the MBP of sending anything to any actuator. Here, a better publishing mechanism would make sense which protects the MBP to publish too exessively.

Alternatively one could think of setting the number of allowed inflight messages for the paho client higher: See https://stackoverflow.com/questions/38751546/send-many-publish-message-too-many-publishes-in-progress-error

MqttException: Too many publishes in progress

Too many publishes in progress (32202)

at org.eclipse.paho.client.mqttv3.internal.ClientState.send(ClientState.java:527)

at org.eclipse.paho.client.mqttv3.internal.ClientComms.internalSend(ClientComms.java:163)

at org.eclipse.paho.client.mqttv3.internal.ClientComms.sendNoWait(ClientComms.java:193)

at org.eclipse.paho.client.mqttv3.MqttAsyncClient.publish(MqttAsyncClient.java:1375)

at org.eclipse.paho.client.mqttv3.MqttClient.publish(MqttClient.java:570)

at de.ipvs.as.mbp.service.messaging.impl.mqtt.MQTTClientConnector.publish(MQTTClientConnector.java:191)

at de.ipvs.as.mbp.service.messaging.PubSubService.publish(PubSubService.java:126)

at de.ipvs.as.mbp.service.rules.execution.actuator_action.ActuatorActionExecutor.execute(ActuatorActionExecutor.java:160)

at de.ipvs.as.mbp.service.rules.RuleExecutor.executeRule(RuleExecutor.java:73)

at de.ipvs.as.mbp.service.rules.RuleEngine.induceRuleExecution(RuleEngine.java:192)

at de.ipvs.as.mbp.service.cep.trigger.CEPTriggerService.lambda$registerTrigger$0(CEPTriggerService.java:87)

at de.ipvs.as.mbp.service.cep.engine.esper.EsperCEPQueryDispatcher.lambda$update$0(EsperCEPQueryDispatcher.java:36)

at java.base/java.lang.Thread.run(Unknown Source)

[schneiti]

Also it seems that unnecessarily many reconnects are performed.