Very interesting! I'm working on a similar project at the moment, but I haven't come across Onyx at all before -- I'll start digging through.
In particular, I'm interested to know if this supports exactly-once messaging semantics, and if so, what the implementation looks like. Anyone here have experience with this?