async def METHOD_NAME(self, channel, method, properties, body):
    body = self.decode_message(body=body)
    file_content = await self._download_image(img_url=body["url"])
    # consume message logic ...