Dhiraj Bokde created AMQ-5112:
---------------------------------
Summary: MQTT server connections are not thread safe
Key: AMQ-5112
URL: https://issues.apache.org/jira/browse/AMQ-5112
Project: ActiveMQ
Issue Type: Bug
Components: MQTT
Affects Versions: 5.9.0
Reporter: Dhiraj Bokde
Priority: Blocker
Fix For: 5.10.0
MQTTProtocolConverter uses MQTTTransportFilter.sendToMQTT() to send packets to
clients. However, there is a race condition where the converter is sending
SUBACK or other acks to clients when ActiveMQ messages from the Broker also try
to call sendToMQTT() to send PUBLISH packets to the same client.
A patch is included which fixes this by synchronizing the call to the
underlying transport buffer in MQTTTransportFilter.sendToMQTT(). This also
resolves another issue AMQ-4712, where some tests would intermittently fail due
to this race condition. Those tests were marked as ignored, so this patch
enables them again.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
