[bugfix]Check rabbitmq connection before send message.

consumer/base.py

@@ -162,6 +162,7 @@ class BasicMessageSender(BasicPikaClient):
         properties = pika.BasicProperties(delivery_mode=pika.spec.PERSISTENT_DELIVERY_MODE,
                                           priority=headers.priority.value if headers else None,
                                           headers=headers.model_dump() if headers else None)
+        self.check_connection()
         self.channel.basic_publish(
             exchange=exchange_name,
             routing_key=routing_key,