Distributed message queue written in D