MQTT Error from Log

All,

Anyone have an idea of what this means ?

2020-04-22 13:41:27.187 [WARN ] [til.concurrent.AbstractEventExecutor] - A task raised an exception. Task: com.hivemq.client.internal.mqtt.handler.publish.incoming.MqttSubscribedPublishFlow@7e8605

java.lang.IllegalStateException: null

at com.hivemq.client.internal.util.collections.ChunkedArrayQueue$ChunkedArrayQueueIterator.remove(ChunkedArrayQueue.java:210) ~[?:?]

at com.hivemq.client.internal.mqtt.handler.publish.incoming.MqttIncomingPublishService.drain(MqttIncomingPublishService.java:131) ~[?:?]

at com.hivemq.client.internal.mqtt.handler.publish.incoming.MqttIncomingPublishFlow.run(MqttIncomingPublishFlow.java:137) ~[?:?]

at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163) [bundleFile:4.1.42.Final]

at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:510) [bundleFile:4.1.42.Final]

at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:518) [bundleFile:4.1.42.Final]

at io.netty.util.concurrent.SingleThreadEventExecutor$6.run(SingleThreadEventExecutor.java:1044) [bundleFile:4.1.42.Final]

at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) [bundleFile:4.1.42.Final]

at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [bundleFile:4.1.42.Final]

at java.lang.Thread.run(Thread.java:748) [?:1.8.0_222]

2020-04-22 13:41:27.212 [WARN ] [til.concurrent.AbstractEventExecutor] - A task raised an exception. Task: com.hivemq.client.internal.mqtt.handler.MqttSession$$Lambda$721/13680595@bbd4ba

java.lang.IllegalStateException: null

at com.hivemq.client.internal.util.collections.ChunkedArrayQueue$ChunkedArrayQueueIterator.remove(ChunkedArrayQueue.java:210) ~[?:?]

at com.hivemq.client.internal.mqtt.handler.publish.incoming.MqttIncomingPublishService.drain(MqttIncomingPublishService.java:131) ~[?:?]

at com.hivemq.client.internal.mqtt.handler.publish.incoming.MqttIncomingPublishFlow.onError(MqttIncomingPublishFlow.java:105) ~[?:?]

at com.hivemq.client.internal.mqtt.handler.publish.incoming.MqttSubscriptionFlowTree$TopicTreeNode.clear(MqttSubscriptionFlowTree.java:335) ~[?:?]

at com.hivemq.client.internal.mqtt.handler.publish.incoming.MqttSubscriptionFlowTree$TopicTreeNode.lambda$clear$0(MqttSubscriptionFlowTree.java:346) ~[?:?]

at java.util.HashMap$Values.forEach(HashMap.java:981) ~[?:1.8.0_222]

at com.hivemq.client.internal.mqtt.handler.publish.incoming.MqttSubscriptionFlowTree$TopicTreeNode.clear(MqttSubscriptionFlowTree.java:346) ~[?:?]

at com.hivemq.client.internal.mqtt.handler.publish.incoming.MqttSubscriptionFlowTree$TopicTreeNode.lambda$clear$0(MqttSubscriptionFlowTree.java:346) ~[?:?]

at java.util.HashMap$Values.forEach(HashMap.java:981) ~[?:1.8.0_222]

at com.hivemq.client.internal.mqtt.handler.publish.incoming.MqttSubscriptionFlowTree$TopicTreeNode.clear(MqttSubscriptionFlowTree.java:346) ~[?:?]

at com.hivemq.client.internal.mqtt.handler.publish.incoming.MqttSubscriptionFlowTree.clear(MqttSubscriptionFlowTree.java:96) ~[?:?]

at com.hivemq.client.internal.mqtt.handler.publish.incoming.MqttIncomingPublishFlows.clear(MqttIncomingPublishFlows.java:153) ~[?:?]

at com.hivemq.client.internal.mqtt.handler.publish.incoming.MqttIncomingQosHandler.onSessionEnd(MqttIncomingQosHandler.java:241) ~[?:?]

at com.hivemq.client.internal.mqtt.handler.MqttSession.end(MqttSession.java:113) ~[?:?]

at com.hivemq.client.internal.mqtt.handler.MqttSession.lambda$expire$0(MqttSession.java:97) ~[?:?]

at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163) [bundleFile:4.1.42.Final]

at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:510) [bundleFile:4.1.42.Final]

at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:518) [bundleFile:4.1.42.Final]

at io.netty.util.concurrent.SingleThreadEventExecutor$6.run(SingleThreadEventExecutor.java:1044) [bundleFile:4.1.42.Final]

at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) [bundleFile:4.1.42.Final]

at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [bundleFile:4.1.42.Final]

at java.lang.Thread.run(Thread.java:748) [?:1.8.0_222]

2020-04-22 13:41:27.256 [WARN ] [til.concurrent.AbstractEventExecutor] - A task raised an exception. Task: com.hivemq.client.internal.mqtt.handler.publish.incoming.MqttSubscribedPublishFlow@be198b

java.lang.IllegalStateException: null

at com.hivemq.client.internal.util.collections.ChunkedArrayQueue$ChunkedArrayQueueIterator.remove(ChunkedArrayQueue.java:210) ~[?:?]

at com.hivemq.client.internal.mqtt.handler.publish.incoming.MqttIncomingPublishService.drain(MqttIncomingPublishService.java:131) ~[?:?]

at com.hivemq.client.internal.mqtt.handler.publish.incoming.MqttIncomingPublishFlow.run(MqttIncomingPublishFlow.java:137) ~[?:?]

at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163) [bundleFile:4.1.42.Final]

at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:510) [bundleFile:4.1.42.Final]

at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:518) [bundleFile:4.1.42.Final]

at io.netty.util.concurrent.SingleThreadEventExecutor$6.run(SingleThreadEventExecutor.java:1044) [bundleFile:4.1.42.Final]

at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) [bundleFile:4.1.42.Final]

at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [bundleFile:4.1.42.Final]

at java.lang.Thread.run(Thread.java:748) [?:1.8.0_222]

All,

So I solved this after some google searches, essentially I misplaced some {} and I was spamming the MQTT server sending a messages as fast as the sensor could send out the data. I confirmed this by looking at the raw data with MQTTFX, the server would also get disconnected After correcting the errors with the {} the issues went away.