[CAMEL-11628] MQTT Connection loop

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.17.0
• Fix Version/s: 2.19.5, 2.20.1, 2.21.0
• Component/s: camel-mqtt
• Estimated Complexity: Unknown
• Assignee: Claus Ibsen
• Reporter: Fabrizio Spataro
• Created: 03/Aug/17 08:34
• Updated: 04/Nov/17 13:20
• Resolved: 04/Nov/17 09:45

Description

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

Issue Links

• is related to: CAMEL-11989 camel-paho - Allow to specify topic via header
• links to: GitHub Pull Request #2077
• links to: GitHub Pull Request #2077