code: def get_message(self):
          
          try:
              m = self.get_from_backend()
              if m and m["type"] not in SKIP_TYPES:
                  return self.decrypt(m["data"])
  
          except AttributeError:
              raise Exception("Tried to call get message without having subscribed first!")
          except (KeyboardInterrupt, SystemExit):
              pass
          except:
              logging.critical("Error in watching pubsub get message: \n%s" % traceback.format_exc())
          return None
docs: Gets the latest object from the backend, and handles unpickling
          and validation.