Skip to content
Branch: master
Go to file

Latest commit


Failed to load latest commit information.
Latest commit message
Commit time

Cylon.js API Plugin For MQTT

Cylon.js ( is a JavaScript framework for robotics, physical computing, and the Internet of Things using Node.js

API plugins are separate from the Cylon.js main module, to make everything more modular and at the same time make Cylon.js lighter.

This repository contains the Cylon API plugin for the MQTT ( machine to machine messaging system. The implementation uses the mqtt node module maintained by @adamvr and @mcollina thank you!

For more information about Cylon, check out the repo at

Build Status Code Climate Test Coverage

How to Install

$ npm install cylon-api-mqtt

How to Use

Make sure you have Cylon.js installed, then we can add MQTT support to cylon programs as follows:

'use strict';

var Cylon = require('cylon');

  name: 'cybot',

  connections: {
    arduino: { adaptor: 'firmata', port: '/dev/ttyACM0' }

  devices: {
    led: { driver: 'led', pin: 13 }

  work: function() {
    // Add your robot code here,
    // for this simple blink example
    // we'll interacting with the
    // robot through the 'led' device.

// ensure you install the API plugin first:
// $ npm install cylon-api-mqtt
  broker: 'mqtt://',
  port: '3000'


How to Connect

Once you have added the api to your Cylon.js code, and your robots are up and running, you can communicate with it using the MQTT broker.

You send commands to the robot by publishing MQTT messages to the broker intended for that robot using an MQTT topic matching the CPPP.IO ( based route.

You subscribe to events from that robot, again by using the correct MQTT topic matching the CPPP.IO ( based route.

'use strict';

var mqtt    = require('mqtt');
var client  = mqtt.connect('mqtt://');

client.on('message', function (topic, payload) {
  var data, sender;

  if (!!payload && (payload.length > 0)) {
    data = JSON.parse(payload);
    sender = data.sender;

  if (sender !== 'self') {
    console.log('Topic name ==>', topic);
    console.log('Payload ==>', data);

var params = {
  sender: 'self',
  args: ['param1', 'param2', 'param3']

// Payload needs to be a JSON string
var payload = JSON.stringify(params);

// get response messages from the robot-level command `toggle`

setInterval(function() {
  // call robot-level command `toggle`
}, 2000);

You can also send commands or subscribe to events directly on any robot's devices. Take a look at the examples folder for more samples.


We're busy adding documentation to Please check there as we continue to work on Cylon.js.

Thank you!


For our contribution guidelines, please go to

Release History

For the release history, please go to


Copyright (c) 2014-2015 The Hybrid Group. Licensed under the Apache 2.0 license.


Cylon.js API plugin for MQTT



Contributors 4

You can’t perform that action at this time.