diff --git a/app/service/generate_image/service_generate_image.py b/app/service/generate_image/service_generate_image.py
index 4ed8fd4..cfd5fd5 100644
--- a/app/service/generate_image/service_generate_image.py
+++ b/app/service/generate_image/service_generate_image.py
@@ -180,6 +180,7 @@ class GenerateImage:
             dict_generate_data, str_generate_data = self.read_tasks_status()
             if DEBUG is False:
                 self.channel.basic_publish(exchange='', routing_key=GI_RABBITMQ_QUEUES, body=str_generate_data)
+                self.connection.close()
             # self.channel.basic_publish(exchange='', routing_key=GI_RABBITMQ_QUEUES, body=str_generate_data)
             logger.info(f" [x] Sent {json.dumps(dict_generate_data, indent=4)}")
 
diff --git a/app/service/generate_image/service_generate_multi_view.py b/app/service/generate_image/service_generate_multi_view.py
index c930ab2..248e604 100644
--- a/app/service/generate_image/service_generate_multi_view.py
+++ b/app/service/generate_image/service_generate_multi_view.py
@@ -105,6 +105,7 @@ class GenerateMultiView:
             dict_generate_data, str_generate_data = self.read_tasks_status()
             if DEBUG is False:
                 self.channel.basic_publish(exchange='', routing_key=GMV_RABBITMQ_QUEUES, body=str_generate_data)
+                self.connection.close()
             # self.channel.basic_publish(exchange='', routing_key=GI_RABBITMQ_QUEUES, body=str_generate_data)
             logger.info(f" [x] Sent {json.dumps(dict_generate_data, indent=4)}")
 
diff --git a/app/service/generate_image/service_generate_single_logo.py b/app/service/generate_image/service_generate_single_logo.py
index e3def3e..af182b2 100644
--- a/app/service/generate_image/service_generate_single_logo.py
+++ b/app/service/generate_image/service_generate_single_logo.py
@@ -98,6 +98,7 @@ class GenerateSingleLogoImage:
             dict_generate_data, str_generate_data = self.read_tasks_status()
             if DEBUG is False:
                 self.channel.basic_publish(exchange='', routing_key=GI_RABBITMQ_QUEUES, body=str_generate_data)
+                self.connection.close()
             logger.info(f" [x] Sent {json.dumps(dict_generate_data, indent=4)}")