diff --git a/app/service/generate_image/service_generate_product_image.py b/app/service/generate_image/service_generate_product_image.py
index d0fbe74..5d67eef 100644
--- a/app/service/generate_image/service_generate_product_image.py
+++ b/app/service/generate_image/service_generate_product_image.py
@@ -320,6 +320,7 @@ class GenerateProductImage:
             dict_gen_product_data, str_gen_product_data = self.read_tasks_status()
             if DEBUG is False:
                 self.channel.basic_publish(exchange='', routing_key=GPI_RABBITMQ_QUEUES, body=str_gen_product_data)
+                self.connection.close()
             logger.info(f" [x] Sent to： {GPI_RABBITMQ_QUEUES} data：@@@@  {json.dumps(dict_gen_product_data, indent=4)}")
 
 
diff --git a/app/service/generate_image/service_generate_relight_image.py b/app/service/generate_image/service_generate_relight_image.py
index 668e7fd..06a8954 100644
--- a/app/service/generate_image/service_generate_relight_image.py
+++ b/app/service/generate_image/service_generate_relight_image.py
@@ -139,6 +139,7 @@ class GenerateRelightImage:
             dict_gen_product_data, str_gen_product_data = self.read_tasks_status()
             if DEBUG is False:
                 self.channel.basic_publish(exchange='', routing_key=GRI_RABBITMQ_QUEUES, body=str_gen_product_data)
+                self.connection.close()
             logger.info(f" [x] Sent to： {GRI_RABBITMQ_QUEUES} data：@@@@  {json.dumps(dict_gen_product_data, indent=4)}")
 
 
diff --git a/app/service/generate_image/service_pose_transform.py b/app/service/generate_image/service_pose_transform.py
index 3fc65c6..07da8de 100644
--- a/app/service/generate_image/service_pose_transform.py
+++ b/app/service/generate_image/service_pose_transform.py
@@ -29,6 +29,9 @@ logger = logging.getLogger()
 
 class PoseTransformService:
     def __init__(self, request_data):
+        if DEBUG is False:
+            self.connection = pika.BlockingConnection(pika.ConnectionParameters(**RABBITMQ_PARAMS))
+            self.channel = self.connection.channel()
         self.grpc_client = grpcclient.InferenceServerClient(url=PT_MODEL_URL)
         self.redis_client = redis.StrictRedis(host=REDIS_HOST, port=REDIS_PORT, db=REDIS_DB, decode_responses=True)
         self.category = "pose_transform"
@@ -108,9 +111,8 @@ class PoseTransformService:
         finally:
             dict_pose_transform_data, str_pose_transform_data = self.read_tasks_status()
             if DEBUG is False:
-                connection = pika.BlockingConnection(pika.ConnectionParameters(**RABBITMQ_PARAMS))
-                channel = connection.channel()
-                channel.basic_publish(exchange='', routing_key=PS_RABBITMQ_QUEUES, body=str_pose_transform_data)
+                self.channel.basic_publish(exchange='', routing_key=PS_RABBITMQ_QUEUES, body=str_pose_transform_data)
+                self.connection.close()
             logger.info(f" [x] Sent to： {PS_RABBITMQ_QUEUES} data：@@@@  {json.dumps(dict_pose_transform_data, indent=4)}")