code: def get_command(self):
          
          try:
              message_bytes = self.socket.recv(zmq.NOBLOCK)
              log.debug("Received message: %r", message_bytes)
          except zmq.ZMQError as exc:
              if exc.errno == zmq.EAGAIN:
                  return None
              else:
                  raise
          else:
              return message_bytes.decode(config.CODEC)
docs: Attempt to return a unicode object from the command socket
          
          If no message is available without blocking (as opposed to a blank 
          message), return None