Implemented parsing RCP messages at ZMQ stream listener