ETL and processors adapted to used 0MQ intelligent messaging service instead of Python queues; using ujson for faster serialization through 0MQ sockets