parameters: (self, response, unpacked_data, unpack_exception)
docstring: Called when a queued message is returned.
docstring_summary: Called when a queued message is returned.
docstring_tokens: Called when a queued message is returned .
function: def _QueuedMessageComplete(self, response, unpacked_data, unpack_exception):
      """Called when a queued message is returned."""
      if not self._CheckForAckOrNack(response):
        return
  
      if response.response_type == OlaClient.RDM_NACK_REASON:
        if (self.outstanding_pid and
            response.command_class == OlaClient.RDM_GET_RESPONSE and
            response.pid == self.outstanding_pid.value):
          # we found what we were looking for
          print("found, but nacked")
          self.outstanding_pid = None
          self._NextState()
  
        elif (response.nack_reason == RDMNack.NR_UNKNOWN_PID and
              response.pid == self.pid_store.GetName('QUEUED_MESSAGE').value):
          logging.debug('Device doesn\'t support queued messages')
          self._NextState()
        else:
          print('Got nack for 0x%04hx with reason: %s' % (
              response.pid, response.nack_reason))
  
      elif unpack_exception:
        print('Invalid Param data: %s' % unpack_exception)
      else:
        status_messages_pid = self.pid_store.GetName('STATUS_MESSAGES')
        queued_message_pid = self.pid_store.GetName('QUEUED_MESSAGE')
        if (response.pid == status_messages_pid.value and
            unpacked_data.get('messages', []) == []):
          logging.debug('Got back empty list of STATUS_MESSAGES')
          self._NextState()
          return
        elif response.pid == queued_message_pid.value:
          logging.debug('Got back QUEUED_MESSAGE, this is a bad responder')
          self._NextState()
          return
  
        logging.debug('Got pid 0x%hx' % response.pid)
        if self.outstanding_pid and response.pid == self.outstanding_pid.value:
          self._HandleResponse(unpacked_data)
        else:
          self._FetchQueuedMessages()
function_tokens: def _QueuedMessageComplete ( self , response , unpacked_data , unpack_exception ) : if not self . _CheckForAckOrNack ( response ) : return if response . response_type == OlaClient . RDM_NACK_REASON : if ( self . outstanding_pid and response . command_class == OlaClient . RDM_GET_RESPONSE and response . pid == self . outstanding_pid . value ) : # we found what we were looking for print ( "found, but nacked" ) self . outstanding_pid = None self . _NextState ( ) elif ( response . nack_reason == RDMNack . NR_UNKNOWN_PID and response . pid == self . pid_store . GetName ( 'QUEUED_MESSAGE' ) . value ) : logging . debug ( 'Device doesn\'t support queued messages' ) self . _NextState ( ) else : print ( 'Got nack for 0x%04hx with reason: %s' % ( response . pid , response . nack_reason ) ) elif unpack_exception : print ( 'Invalid Param data: %s' % unpack_exception ) else : status_messages_pid = self . pid_store . GetName ( 'STATUS_MESSAGES' ) queued_message_pid = self . pid_store . GetName ( 'QUEUED_MESSAGE' ) if ( response . pid == status_messages_pid . value and unpacked_data . get ( 'messages' , [ ] ) == [ ] ) : logging . debug ( 'Got back empty list of STATUS_MESSAGES' ) self . _NextState ( ) return elif response . pid == queued_message_pid . value : logging . debug ( 'Got back QUEUED_MESSAGE, this is a bad responder' ) self . _NextState ( ) return logging . debug ( 'Got pid 0x%hx' % response . pid ) if self . outstanding_pid and response . pid == self . outstanding_pid . value : self . _HandleResponse ( unpacked_data ) else : self . _FetchQueuedMessages ( )