Publish/Subscribe messaging system with mariotcp server