MQTT Channel

MQTT is a machine-to-machine connectivity protocol that enables remote connections for IoT applications. By using the MQTT channel, TIBCO BusinessEvents can receive MQTT messages and transform them into TIBCO BusinessEvents events.

For more information on MQTT, see MQTT Documentation.

Catalog Functions

Using the MQTT channel, you can send simple events with functions like Event.replyEvent(), Event.routeTo(), and Event.sendEvent(). You can also create synchronous request and response of events by using Event.requestEvent().

MQTT Channel Serializers

MQTT channel provides the following serializers to handle payloads:

MQTTMapSerializer
MQTTMapSerializer (com.tibco.cep.driver.mqtt.serializer.MqttMapSerializer) serializes and deserializes TIBCO BusinessEvents events along with its payload into (or from) a Java map. The MQTTMapSerializer is used to send and receive events among TIBCO BusinessEvents instances. For incoming messages, the deserializer converts the bytes of Java Map to an event and its payload. For outgoing events, the serializer converts the event and its payload into bytes of Java map.
MQTTJsonSerializer
MQTTJsonSerializer (com.tibco.cep.driver.mqtt.serializer.MqttJsonSerializer) serializes and deserializes a TIBCO BusinessEvents event along with its payload into (or from) JSON. For incoming messages, the MQTTJsonSerializer deserializes the text from the message (as a JSON string) to an event. For outgoing events, the serializer converts the event and its payloads into a JSON string. The MQTTJsonSerializer serializer is useful for processing or sending messages between TIBCO BusinessEvents and external systems.

MQTT Channel Example

A sample TIBCO BusinessEvents application that uses the MQTT channel is available under BE_HOME/examples/standard/MQTTChannel.