original_docstring: Check if a message of the given type and id is in the queue
docstring: Check if a message of the given type and id is in the queue
docstring_tokens: Check if a message of the given type and id is in the queue
code: def _check_for_message(self, match_type, match_id):
          """Check if a message of the given type and id is in the queue"""
          while True:
              try:
                  msg_type, msg_id, msg_data = self.dev.GetNextMessage()
              except KinesisError:
                  return False
  
              log.debug("Received kinesis message ({},{},{})".format(msg_type, msg_id, msg_data))
              if msg_type == match_type and msg_id == match_id:
                  return True
code_tokens: def _check_for_message ( self , match_type , match_id ) : while True : try : msg_type , msg_id , msg_data = self . dev . GetNextMessage ( ) except KinesisError : return False log . debug ( "Received kinesis message ({},{},{})" . format ( msg_type , msg_id , msg_data ) ) if msg_type == match_type and msg_id == match_id : return True
short_docstring: Check if a message of the given type and id is in the queue
short_docstring_tokens: Check if a message of the given type and id is in the queue
comment: """Check if a message of the given type and id is in the queue"""