diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts
index 771d73d7..0908e907 100644
--- a/src/services/rabbitmq.ts
+++ b/src/services/rabbitmq.ts
@@ -49,7 +49,7 @@ export async function init() {
 
 let retries = 0;
 
-function createConsumer( //----> consumer
+async function createConsumer( //----> consumer
   queue: string,
   channel: amqp.Channel,
   handler: (msg: amqp.ConsumeMessage) => Promise<boolean> | boolean,