Lightweight publish-subscribe & distributed queueing messaging system