semvec/pypi-packages huggingface dataset:
msgflo 0.4.1
Simple message queueing for AMQP and MQTT
License: MIT License

# msgflo-python: Python participant support for MsgFlo

[MsgFlo](https://github.com/msgflo/msgflo) is a distributed, polyglot FBP (flow-based-programming) runtime.
It integrates with other FBP tools like the [Flowhub](http://flowhub.io) visual programming IDE.
This library makes it easy to create MsgFlo participants in Python.

msgflo-python is built on top of [gevent](http://www.gevent.org/).
It uses [Haigha](https://github.com/agoragames/haigha) for AMQP support
and [Eclipse Paho](https://eclipse.org/paho/clients/python/) for MQTT.

## Status

*In production*

* Support for MQTT 3.1.1, incl TLS
* Support for AMQP 0.9.0 / RabbitMQ
* Support for Python 3.5+ and Python 2.7+

[Changelog](./CHANGES.md)

## License

MIT, see [./LICENSE](./LICENSE)

## Installing

Get it from [PyPi](http://pypi.python.org/)

    pip install msgflo --user

## Usage

See [./examples/repeat.py](./examples/repeat.py)

    wget https://github.com/msgflo/msgflo-python/raw/master/examples/repeat.py
    # Set address of broker to connect to. Can also be amqp://...
    export MSGFLO_BROKER=mqtt://localhost
    python ./repeat.py