docs: def reconnect_to_broker(self):
          """Connect or reconnect to broker"""
          #print "CONNECT !"
          if self.client:
              self.poller.unregister(self.client)
              self.client.close()
          self.client = self.ctx.socket(zmq.DEALER)
          self.client.linger = 0
          self.client.connect(self.broker)
          self.poller.register(self.client, zmq.POLLIN)
          if self.verbose:
              logging.info("I: connecting to broker at %s...", self.broker)