0mq: add a collector of data, and an agent that subscribes to all data