Concurrent persistent message queue written in Go - View it on GitHub