ZMQ-source: handle the message and put it in the queue