+ neededsubs = clients.subs()
+ for imei in neededsubs - activesubs:
+ zsub.setsockopt(zmq.SUBSCRIBE, imei.encode())
+ for imei in activesubs - neededsubs:
+ zsub.setsockopt(zmq.UNSUBSCRIBE, imei.encode())
+ activesubs = neededsubs
+ log.debug("Subscribed to: %s", activesubs)