Caught up on sleep last night :-P So, I actually wrote about half of it as an Atomix resource, but TBH it but doesn't quite feel right. This probably needs to be done in the Orwell project where it was originally going to be done. It just makes more sense to be built on top of Atomix rather than in it, not to mention it will be a lot easier and less complex. But I also got side tracked experimenting with sharding in Atomix which may actually be more feasible than I thought. I am probably going to try to finish up that experiment before I throw together the Orwell API, but I think Orwell should be a fairly easy task built on top of Atomix. To that end, I'm also making some improvements to
DistributedMessageBus to allow a thread-per-consumer.