initial implementation of zmq_subscription_aggregator.py