Fabrizio Spataro created CAMEL-11628: ----------------------------------------
Summary: MQTT Connection loop Key: CAMEL-11628 URL: https://issues.apache.org/jira/browse/CAMEL-11628 Project: Camel Issue Type: Bug Components: camel-mqtt Reporter: Fabrizio Spataro Hello everyone, i found an particular bug situation I have same mqtt producer with high volume traffic. When my application losts tcp connection to mqtt server i have follow connection loop error. This bug is sometime verified because it depend by multiple factors (load machine, load mqtt server, payload, etc) I am reading source code and i suppose that the bug is introduced by volatile variable connected (it isn't thread-safe) To resolve this bug you must refactoring all MQTTEndpoint connection code. ``` [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 [ hawtdispatch-DEFAULT-3] MQTTEndpoint INFO MQTT Connection connected to tcp://mqtt:1883 ``` -- This message was sent by Atlassian JIRA (v6.4.14#64029)