def _process_message(self, message: amqp.Message) -> None:
if self.shutdown_pending.is_set():<EOL><INDENT>return<EOL><DEDENT>try:<EOL><INDENT>if isinstance(message.body, bytes):<EOL><INDENT>message.body = message.body.decode()<EOL><DEDENT>description = json.loads(message.body)<EOL><DEDENT>except Exception:<EOL><INDENT>logger.error("<STR_LIT>", message.body)<EOL>traceback.print_exc()<EOL>message.channel.basic_reject(message.delivery_tag, requeue=False)<EOL><DEDENT>else:<EOL><INDENT>logger.info("<STR_LIT>", description)<EOL>self._process_description(message, description)<EOL><DEDENT>
Processes the message received from the queue.