Aggregates and distributes messages with Go and ZMQ