diff --git a/index.js b/index.js
index fc95f30..913fb9d 100644
--- a/index.js
+++ b/index.js
@@ -148,7 +148,6 @@ function start() {
       try {
         await retryEmail(handlers)
       } catch (err) {
-        console.log(err);
         logger.error(err);
       }
     });
diff --git a/src/init.js b/src/init.js
index 3168be8..11e41c9 100644
--- a/src/init.js
+++ b/src/init.js
@@ -57,12 +57,10 @@ async function dataHandler(consumer, handlers) {
         // return null to ignore this message
         return null;
       }
-      console.log([1])
       const emailModel = await models.loadEmailModule()
       const busPayload = JSON.parse(message);
       const messageJSON = busPayload.payload;
       try {
-
         const emailInfo = {
           status: 'PENDING',
           topicName,
@@ -70,13 +68,7 @@ async function dataHandler(consumer, handlers) {
           recipients: JSON.stringify(messageJSON.recipients),
         }
 
-        try {
-          console.log(emailModel)
-          await emailModel.create(emailInfo)
-
-        } catch (err) {
-          console.log(err)
-        }
+        await emailModel.create(emailInfo)
         const result = await handler(topicName, messageJSON);
 
         logger.info('info', 'Email sent', {
@@ -86,7 +78,7 @@ async function dataHandler(consumer, handlers) {
           status: result.success ? 'Message accepted' : 'Message rejected',
           error: result.error ? result.error.toString() : 'No error message',
         });
-
+        const emailTries = {}
         if (result.success) {
           emailTries[topicName] = 0;
           emailModel.status = 'SUCCESS';
@@ -98,7 +90,6 @@ async function dataHandler(consumer, handlers) {
           }
         }
       } catch (e) {
-        console.log(e)
         logger.error(e)
       }