def _validate_message_type(self):
        """Check to see if the current message's AMQP type property is
        supported and if not, raise either a :exc:`DropMessage` or
        :exc:`MessageException`.

        :raises: DropMessage
        :raises: MessageException

        """
        if self._unsupported_message_type():
            self.logger.warning(
                'Received unsupported message type: %s', self.message_type)
            if self._drop_invalid:
                if self._drop_exchange:
                    self._republish_dropped_message('invalid type')
                raise DropMessage
            raise MessageException
Check to see if the current message's AMQP type property is
        supported and if not, raise either a :exc:`DropMessage` or
        :exc:`MessageException`.

        :raises: DropMessage
        :raises: MessageException