[bugfix]Bugfix.

consumer/base.py

@@ -38,6 +38,8 @@ class Headers(BaseModel):
     @field_validator('priority', mode='before')
     @classmethod
     def _convert_priority(cls, value):
+        if isinstance(value, Priority):
+            return value
         return Priority[value]
 
 
@@ -176,8 +178,6 @@ class BasicMessageReceiver(BasicPikaClient):
 
     def decode_message(self, body):
         if type(body) == bytes:
-            return msgpack.unpackb(body)
-        elif type(body) == str:
             return json.loads(body)
         else:
             raise NotImplementedError
@@ -207,29 +207,3 @@ class BasicMessageReceiver(BasicPikaClient):
             self.channel_tag = None
         else:
             logger.error("Do not cancel a non-existing job")
-
-
-class ExtractFaceFramesConsumer(BasicMessageReceiver):
-    @sync
-    async def consume(self, channel, method, properties, body):
-        body = self.decode_message(body=body)
-        file_content = await self._download_image(img_url=body["url"])
-        # consume message logic ...
-
-    async def _download_image(self, img_url):
-        # do some async stuff here
-        pass
-
-
-def create_consumer():
-    worker = ExtractFaceFramesConsumer()
-    worker.declare_queue(queue_name="myqueue")
-    worker.declare_exchange(exchange_name="myexchange")
-    worker.bind_queue(
-        exchange_name="myexchange", queue_name="myqueue", routing_key="randomkey"
-    )
-    worker.consume_messages(queue="myqueue", callback=worker.consume)
-
-
-if __name__ == "__main__":
-    create_consumer()