[ActiveMQ] MQTT Link Stealing not working

[Blubb <ti...@gmx.de>]

Hey folks,

according to the documentation link stealing should be allowed for MQTT 
Endpoints by default.


Unfortunately this does not seem to be working: Whenever I try to 
reconnect, an exception is raised, that the client is already connected:


2016-05-27 15:12:48.547  WARN 3800 --- [.0.1:59223@1883] 
o.a.a.b.TransportConnection.Transport    : Transport Connection to: 
tcp://127.0.0.1:59223 failed: java.io.IOException: Broker: localhost - 
Client: asd_212041185 already connected from tcp://127.0.0.1:59221


I have also tried to append ?allowLinkStealing=true to the mqtt uri, but 
still not working. Any ideas?


Environment:

         <dependency>
             <groupId>org.apache.activemq</groupId>
             <artifactId>activemq-core</artifactId>
             <version>5.7.0</version>
         </dependency>

         <dependency>
             <groupId>org.apache.activemq</groupId>
             <artifactId>activemq-broker</artifactId>
             <version>5.13.3</version>
         </dependency>


BR