MQTT Android не подключается к ActiveMq

Question

Я пытаюсь подключить Android-приложение к серверу ActiveMQ. Я использую ActiveMQ, потому что мой сервер уже разговаривает с сервером ActiveMQ с помощью JMS, поэтому мне будет очень полезно подключить клиент android к брокеру JMS.

Я включил MQTT в ActiveMQ после этой страницы: http://activemq.apache.org/mqtt.html и у меня была небольшая проблема с любым из клиентов MQTT (IBM MQTT клиент или Pāho MQTT Client) Я скачал не узнал «MQTT:// ", поэтому я попытался использовать tcp вместо этого. Это как конфигурация выглядит в activemq.xml:

<transportConnectors> 
    <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireformat.maxFrameSize=104857600"/> 
    <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireformat.maxFrameSize=104857600"/>   
    <transportConnector name="mqtt" uri="tcp://0.0.0.0:1883"/> 
</transportConnectors> 

Когда я пытаюсь подключиться с помощью любого примера MQTT клиента, такие как это одна: http://mosquitto.org/2011/11/android-mqtt-example-project/ Я не могу подключиться к ActiveMQ, и я получаю сообщение об ошибке на серверная сторона:

2013-09-05 12:34:17,550 | WARN | Transport Connection to: tcp://192.168.0.111:42148 failed: java.io.IOException: Unknown data type: 77 | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: tcp:///192.168.0.111:42148@1883 

Любые предложения? Спасибо!

Answer 1

Вы не настроили транспортный коннектор MQTT правильно. Попробуйте это:

<transportConnectors> 
    <transportConnector name="mqtt" uri="mqtt://localhost:1883"/> 
</transportConnectors> 

Обратите внимание, что в вашем вы использовали Uri префикс TCP.