MQTT

MQTT is a lightweight, publish-subscribe, machine to machine network protocol for Message queue/Message queuing service. Joule provides the ability to subscribe to events using MQTT source consumer

Driver details

org.eclipse.paho:org.eclipse.paho.mqttv5.client:1.2.5

Configuration Guide

Example configuration

mqttConsumer:
  broker: tcp://127.0.0.1:1883
  topic: mydevice/leaf

  clientId: myClientId
  username: lyndon
  tenant: uk
  qos: 1

  deserializer:
    transform: com.fractalworks.streams.transport.mqtt.CustomerToStreamEventTranslator
    compressed: false
    batch: false

This basic example leverages the default setting resulting in events consumed from the mydevice/leaf topic as a Customer object. This object is then transformed in to a Joule StreamEvent object to ready for platform processing.

Core Attributes

Available configuration parameters

Deserialization Attributes

This topic provides configuration parameters available object deserialization process.

Deserializer example

deserializer:
  transform: com.fractalworks.streams.transport.mqtt.CustomerToStreamEventTranslator
  compressed: false
  batch: false

Additional Resources

Last updated