This documentation is for WSO2 Enterprise Integrator version 6.2.0 . View documentation for the latest release in the 6.x.x family and the latest release in the 7.x.x family.

All docs This doc
Skip to end of metadata
Go to start of metadata

Note that WSO2 EI is shipped with the following changes to what is mentioned in this documentation:

  • <PRODUCT_HOME>/repository/samples/ directory that includes all Integration profile samples is changed to <EI_HOME>/samples/service-bus/.
  • <PRODUCT_HOME>/repository/samples/resources/ directory that includes all artifacts related to the Integration profile samples is changed to <EI_HOME>/samples/service-bus/resources/.

Introduction

This sample demonstrates how the MQTT connector publishes a message on a particular topic and how a MQTT client that is subscribed to that topic receives it. You can try this sample using the following message brokers:

Using Mosquitto as the Message Broker

Following sections demonstrate how you can try this sample using the Mosquitto server as the Message Broker.

Prerequisites

Follow the steps below before starting the MQTT sample configurations.

  1. Download and install WSO2 EI. For instructions, see Installation Guide.
  2. Download and install Mosquitto. (This sample is tested for Mosquitto1.4.3 version.)
  3. Download MQTT client library (i.e. mqtt-client-0.4.0.jar) and add it to the <EI_HOME>/lib/ directory.

Building the sample

  1. Start the MQTT-supported server. (E.g. Mosquitto)
    • Execute the following command to prepare Mosquitto server for the launch: ln -sfv /usr/local/opt/mosquitto/*.plist ~/Library/LaunchAgents
    • Execute the following command to run the Mosquitto server: launchctl load ~/Library/LaunchAgents/homebrew.mxcl.mosquitto.plist
  2. Open a new Terminal and start the ESB profile of WSO2 EI. For instructions, see Starting the ESB Profile.

  3. Log in to the Management Console, and click Main → Inbound Endpoints → Add inbound Endpoint.

  4. Enter a name for the Inbound Endpoint (e.g., SampleInbound), select MQTT as the type, and click Next.
    enter the inbound endpoint type

  5. Enter the following details, and click Save.

    • SequenceTestIn
    • Error Sequencefault
    • coordinationfalse
    • mqtt.connection.factorymqttConFactory
    • mqtt.server.host.namelocalhost
    • mqtt.server.port1883
    • mqtt.topic.nameesb.test

    inbound endpoint of Mosquitto method

  6. Click Main → Sequences → Add Sequence.

  7. Enter the name of the Sequence as TestIn.

  8. Construct the following sequence.

     Follow the steps below to add the mediators to the sequence.
    1. Add a log mediator as shown below.

      add log mediator
    2. Change the Log Level to FULL in the Log Mediator, and click Update.

    3. Add a property mediator as shown below.


    create the sequence

  9. Click Save & Close.

Executing the sample

In a new Terminal window, execute the following command to publish a message using the Mosquitto publisher.

mosquitto_pub -t esb.test  -m "<msg><a>Testing123</a></msg>"

Analyzing the output

You view the ESB profile receiving the messages in the logs of it in the Terminal as shown below.

Using Broker Profile as the Message Broker

Following sections demonstrate how you can try this sample using the Broker profile of WSO2 EI as the Message Broker.

Prerequisites

Follow the steps below before starting this MQTT sample configurations.

  1. Download and install WSO2 EI. For instructions, see Installation Guide.
  2. Download MQTT client library (i.e. mqtt-client-0.4.0.jar) and add it to the <EI_HOME>/lib/ directory.

Building the sample

  1. Start the Broker profile of WSO2 EI. For instructions, see Starting the Message Broker profile.

  2. Start the ESB profile of WSO2 EI. For instructions, see Starting the ESB Profile.

  3. Log in to the Management Console, and click Main → Inbound Endpoints → Add inbound Endpoint.

  4. Enter a name for the Inbound Endpoint (e.g., SampleInbound), and click Next.
    enter the inbound endpoint type

  5. Enter the following details, and click Save.

    When creating the below Inbound Endpoint, specify the value of mqtt.server.port as 1886 because the Broker profile starts with a default port offset of 3 in WSO2 EI.

    • Sequence: TestIn
    • Error Sequence: fault
    • coordination: false
    • mqtt.connection.factory: mqttConFactory
    • mqtt.server.host.name: localhost
    • mqtt.server.port: 1883
    • mqtt.topic.name: esb.test

    inbound endpoint of Broker profile method

  6. Click Main → Sequences → Add Sequence.

  7. Enter the name of the Sequence as TestIn.

  8. Construct the following sequence.

     Follow the steps below to add the mediators to the sequence.
    1. Add a log mediator as shown below.

      add log mediator
    2. Change the Log Level to FULL in the Log Mediator, and click Update.

    3. Add a property mediator as shown below.


    create the sequence

  9. Click Save & Close.

Executing the sample

In a new Terminal window, execute the following command to publish a message using the Mosquitto publisher.

mosquitto_pub -t esb.test  -m "<msg><a>Testing123</a></msg>"

Analyzing the output

You view the ESB profile receiving the messages in the logs of it in the Terminal as shown below.

  • No labels