2016-08-29 4 views
1

ActiveMQ를 사용하여 다른 Mosquitto 브로커에 연결하는 브로커를 만들고 싶습니다. 그런 다음 ActiveMQ를 사용하여 Mosquitto 브로커의 메시지를받을 수 있습니다.Moquitto 브로커에 연결하기 위해 ActiveMQ MQTT 브로커를 생성하십시오.

은 내가 지금 수행하고 것은 :

  1. 은 제이보스 EAP 6.3으로의 ActiveMQ를 통합 할 수 있습니다. http://activemq.apache.org/mqtt.html

을하지만 브로커-config.xml 파일에 NetworkConnector을 추가 한 후 :

  • 는 ActiveMQ를에서 MQTT 브로커를 만들

    "Network connection between vm://localhost#8 and tcp:///mosquitto_server_ip:[email protected] shutdown due to a remote error: java.util.concurrent.TimeoutException"

    I :

    <transportConnectors> 
        <transportConnector name="openwire" uri="tcp://localhost:61616"/> 
        <transportConnector name="mqtt" uri="mqtt://localhost:1883"/> 
    </transportConnectors> 
    
    <networkConnectors> 
        <networkConnector uri="static:(tcp://mosquitto_server_ip:1883)"/> 
    </networkConnectors> 
    

    서버가 시작한 후 예외를 보여줍니다 또한 "mqtt : // ..."을 사용하여 연결하려고 시도하지만 여전히 실패합니다.

    java.lang.IllegalArgumentException: Invalid connect parameters: {wireFormat.host=0.0.0.0}

    누구든지 JBoss ActiveMQ를 사용하여 모스켓토 브로커에 연결하는 방법을 알고 있습니까?

  • 답변

    0

    ActiveMQ 네트워크 커넥터는 원시 OpenWire 프로토콜을 사용하는 ActiveMQ 브로커에서만 작동하며 MQTT는 지원되지 않습니다. ActiveMQ와 모기 사이의 교차 브로커 통신을 지원하려면 Camel 또는 다른 브리징 메커니즘과 같은 것을 사용해야합니다.

    +0

    Camel을 사용해 본 후에도 작동합니다! 감사! –

    관련 문제