Moving towards zmq_poll for managing queue inputs