В Wso2 ESB, как опубликовать сообщение с помощью mqtt - PullRequest
Новая
       11

В Wso2 ESB, как опубликовать сообщение с помощью mqtt

0 голосов
/ 03 июля 2018

В wso2 esb как опубликовать сообщение, используя mqtt. Я добавил axis2-transport-mqtt-1.0.0.jar и mqtt-client-0.4.0.jar.

И для получения я настроил axis2.xml с 

<transportReceiver class="org.apache.axis2.transport.mqtt.MqttListener" name="mqtt">
        <parameter locked="false" name="mqttConFactory">
                <parameter locked="false" name="mqtt.server.host.name">localhost</parameter>
                <parameter locked="false" name="mqtt.server.port">1883</parameter>
                <parameter locked="false" name="mqtt.client.id">esb.test.listener</parameter>
                <parameter locked="false" name="mqtt.topic.name">esb.test2</parameter>
        </parameter>
    </transportReceiver>

Для публикации сообщения я настроил axis2.xml следующим образом.

Но я не понимаю, как отправить

1 Ответ

0 голосов
/ 04 июля 2018

Привет, как определено здесь https://docs.wso2.com/display/ESB490/Sample+272%3APublishing+and+Subscribing+using+WSO2+ESB%27s+MQ+Telemetry+Transport

вам нужно создать конечную точку с настройками вашего сервера mqtt 

<endpoint>
    <address uri="mqtt:/MyProxyName?mqtt.server.host.name=localhost&amp;mqtt.server.port=1883&amp;mqtt.client.id=esb.test.sender&amp;mqtt.topic.name=esb.test2&amp;mqtt.subscription.qos=2&amp;mqtt.blocking.sender=true"/>
</endpoint>

Изменить с вашими настройками

mqtt.server.host.name : имя хоста посредника сообщений MQTT.

mqtt.server.port : Порт сервера, к которому могут подключаться клиенты. (По умолчанию 1883)

mqtt.topic.name : Имя темы, на которую ESB должен подписаться

mqtt.client.id : используется для идентификации ESB со стороны брокера

затем отправьте полезную нагрузку на эту конечную точку

...