MsgFlo is a distributed, polyglot FBP (flow-based-programming) runtime.
It integrates with other FBP tools like the Flowhub visual programming IDE.
msgflo-rust makes it easy to create MsgFlo participants in Rust.
Working prototype
- Can expose a Rust function on AMQP with a single in/outport
- Sends the MsgFlo participant discovery message on startup
- Passes MsgFlo participant tests
- Not used in any applications yet (as far as we know)
See below TODO section for more notes
Add to your Cargo.toml
[dependencies.msgflo]
git = "https://github.com/msgflo/msgflo-rust"
See ./examples
0.1
- Allow any number of in/outports
- Allow sending multiple messages out
- Make error handling sane
- Add example of consuming/sending JSON data
- Add test for NACK on error condition
- Publish as Rust crate on http://crates.io
Later
- Support 'hidden' ports (not associated with a queue), used as proxies
- Support other transports, like MQTT