activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Blubb <ticket_i...@gmx.de>
Subject [ActiveMQ] MQTT Link Stealing not working
Date Fri, 27 May 2016 07:43:24 GMT
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


Mime
View raw message