CoffeeScript CSS HTML Other
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Failed to load latest commit information.
bin msgflo-jobstats-newrelic: Tool to get job statistics Oct 6, 2015
doc doc: Link FOSDEM 2017 example code and slides Feb 9, 2017
graphs Rename runtime id from fakemsgflo -> msgflo Mar 13, 2015
spec tests: Check non-prefixed components for Procfile generation Feb 16, 2017
src library: Support looking up prefixed from non-prefixed Feb 16, 2017
travis travis: Setup autodeploy for website Feb 2, 2017
.gitignore travis: Setup autodeploy for website Feb 2, 2017
.travis.yml Travis: Start ssh-agent before ssh-add Feb 2, 2017 Bump 0.8.0 Aug 3, 2016
Gemfile Start bootstrapping project website Feb 1, 2017 Gruntfile: Disable silent Feb 2, 2017
LICENSE Mention license, MIT Jun 4, 2015 README: Mention msgflo-browser Feb 16, 2017
fbp-config.json Skeleton FBP runtime protocol implementation Jan 30, 2015
index.js Add missing exports of API Jan 31, 2015

MsgFlo - Flow-Based Programming with Message Queues Build Status

Implementation of the Flow-Based Programming using message queues as the communications layer between different processes. Initial message queue transports targeted are AMQP and MQTT.

MsgFlo lets you build robust polyglot FBP systems spanning multiple computers/devices. A node can be implemented in any language, to reuse existing code, libraries and developer know-how.

In FBP each component is a black-box that processes and produces data, without knowledge about where the input data comes from, or where the output data goes. This ensures that a service is easy to change, and facilitates automated testing.

MsgFlo is designed to enable partial and gradual integration into existing systems; by using standard broker/transports, not placing restrictions on message payloads, allowing to use existing queue names, and integrating non-MsgFlo nodes seamlessly.


In Production

  • Used in production at TheGrid website builder, with AMQP/RabbitMQ. 20 roles, 1'000'000 jobs/weekly+
  • Used in production in imgflo image processing server. 4 roles, 200'000 jobs/weekly+
  • Used for IoT networks at hackerspaces c-base and Bitraf, using MQTT/Mosquitto.

Client support


  • msgflo executable implements the FBP runtime protocol.
  • Initial support for automated testing using fbp-spec
  • Experimental support for visually building networks using Flowhub
  • guv provides autoscaling of workers when using Heroku/AMQP.




Please refer to


The msgflo executable, as well as the transport/participant library uses the debug NPM module. You can enable (all) logging using:

export DEBUG=msgflo*