Difference between revisions of "Edge Messaging"
From RifidiWiki
(Created page with "Prior to Rifidi 3.1 (coming Fall 2014) Edge Messaging is available through ActiveMQ/JMX Interface. Starting in 3.1 Edge Messaging is now accessible though MQTT (Lightweight Io...") |
|||
| (20 intermediate revisions by the same user not shown) | |||
| Line 1: | Line 1: | ||
| − | Prior to Rifidi 3.1 | + | =Introduction= |
| + | Prior to Rifidi 3.1 Edge Messaging is available through [[EdgeServerJMS | ActiveMQ/JMS Interface]]. Starting in 3.1 Edge Messaging is now accessible though MQTT (Lightweight IoT Messaging Protocol through leveraging [https://projects.eclipse.org/projects/iot.moquette Moquette-mqtt plugin]. | ||
This now enables Rifidi Applications to publish events (captured via Rifidi Services for example Readzone Montoring, Stables Set) to a lightweight MQTT messaging queue | This now enables Rifidi Applications to publish events (captured via Rifidi Services for example Readzone Montoring, Stables Set) to a lightweight MQTT messaging queue | ||
| + | =Configuration= | ||
| + | In rifidiserver.ini - A full list of Rifidi Edge configuartion parameters can be found [[Edge_Server_Configuration]] | ||
| − | |||
| − | + | ;-Dorg.rifidi.mqtt.enabled=true | |
| + | :Moquette (MQTT Implementation) starts by default this can be changed | ||
| + | |||
| + | |||
| + | In the config folder is moquette.conf | ||
| + | |||
| + | This is where MQTT TCP, SSL and Websocket port and configuration can be set. | ||
| + | |||
| + | Note: SSL and Websockets support added in Rifidi 3.1.1 | ||
| + | |||
| + | Example | ||
| + | <pre> | ||
| + | |||
| + | ############################################## | ||
| + | # Moquette configuration file. | ||
| + | # | ||
| + | # The synthax is equals to mosquitto.conf | ||
| + | # | ||
| + | ############################################## | ||
| + | |||
| + | port 1883 | ||
| + | |||
| + | websocket_port 8888 | ||
| + | |||
| + | host 0.0.0.0 | ||
| + | |||
| + | #Password file | ||
| + | password_file config/password_file.conf | ||
| + | |||
| + | |||
| + | ssl_port 8883 | ||
| + | |||
| + | jks_path config/serverkeystore.jks | ||
| + | |||
| + | key_store_password password | ||
| + | |||
| + | key_manager_password password | ||
| + | |||
| + | |||
| + | </pre> | ||
| + | |||
| + | |||
| + | Link to Rifidi Source containing MQTT - https://transcends.svn.cloudforge.com/rifidi/rifidi/trunk/org.rifidi.edge/src/org/rifidi/edge/Activator.java | ||
| + | |||
| + | =Clients for Publishings/Subscribing to MqTT Broker= | ||
An example client for subscribing/consuming these messages can be found at [http://www.eclipse.org/paho/ Paho Eclipse IoT/M2M Project] | An example client for subscribing/consuming these messages can be found at [http://www.eclipse.org/paho/ Paho Eclipse IoT/M2M Project] | ||
| + | |||
| + | =Example Rifidi MQTT Integration Application= | ||
| + | |||
| + | *[http://wiki.rifidi.net/index.php?title=Messaging_(MQTT)_Integration_Jumpstart Link to Rifidi MQTT Jumpstart App] | ||
Latest revision as of 20:58, 15 July 2016
Contents
Introduction
Prior to Rifidi 3.1 Edge Messaging is available through ActiveMQ/JMS Interface. Starting in 3.1 Edge Messaging is now accessible though MQTT (Lightweight IoT Messaging Protocol through leveraging Moquette-mqtt plugin.
This now enables Rifidi Applications to publish events (captured via Rifidi Services for example Readzone Montoring, Stables Set) to a lightweight MQTT messaging queue
Configuration
In rifidiserver.ini - A full list of Rifidi Edge configuartion parameters can be found Edge_Server_Configuration
- -Dorg.rifidi.mqtt.enabled=true
- Moquette (MQTT Implementation) starts by default this can be changed
In the config folder is moquette.conf
This is where MQTT TCP, SSL and Websocket port and configuration can be set.
Note: SSL and Websockets support added in Rifidi 3.1.1
Example
############################################## # Moquette configuration file. # # The synthax is equals to mosquitto.conf # ############################################## port 1883 websocket_port 8888 host 0.0.0.0 #Password file password_file config/password_file.conf ssl_port 8883 jks_path config/serverkeystore.jks key_store_password password key_manager_password password
Link to Rifidi Source containing MQTT - https://transcends.svn.cloudforge.com/rifidi/rifidi/trunk/org.rifidi.edge/src/org/rifidi/edge/Activator.java
Clients for Publishings/Subscribing to MqTT Broker
An example client for subscribing/consuming these messages can be found at Paho Eclipse IoT/M2M Project
