activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Dhiraj Bokde (JIRA)" <>
Subject [jira] [Created] (AMQ-5112) MQTT server connections are not thread safe
Date Wed, 19 Mar 2014 23:47:42 GMT
Dhiraj Bokde created AMQ-5112:

             Summary: MQTT server connections are not thread safe
                 Key: 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

View raw message