ØMQ message queue API implementation