code: def process_data_events(self, to_tuple=False, auto_decode=True):
          
          if not self._consumer_callbacks:
              raise AMQPChannelError('no consumer callback defined')
          for message in self.build_inbound_messages(break_on_empty=True,
                                                     auto_decode=auto_decode):
              consumer_tag = message._method.get('consumer_tag')
              if to_tuple:
                  # noinspection PyCallingNonCallable
                  self._consumer_callbacks[consumer_tag](*message.to_tuple())
                  continue
              # noinspection PyCallingNonCallable
              self._consumer_callbacks[consumer_tag](message)
docs: Consume inbound messages.
  
          :param bool to_tuple: Should incoming messages be converted to a
                                tuple before delivery.
          :param bool auto_decode: Auto-decode strings when possible.
  
          :raises AMQPChannelError: Raises if the channel encountered an error.
          :raises AMQPConnectionError: Raises if the connection
                                       encountered an error.
  
          :return: