fix: get message from Message object

src/processors/job/job.processor.coffee

@@ -32,7 +32,12 @@ module.exports =
         request: _.omit error.detail.request, ["resolveWithFullResponse"]
       }
       @_ifJobIsNotStopped message, () => 
+        console.log("Max retry exceeded for job #{message.JobId} with error #{errorMessage.error}")
+        console.log("Sending NotificationsApi fail")
         @_notificationsApi(message).fail errorMessage
+          .then (response) =>
+            console.log("NotificationsApi fail response: #{response}")
+            response
           .throw new NonRetryable "Max retry exceeded", error
 
     _notificationsApi: ({ HeadersForRequest, JobId }) =>

src/processors/job/notification.api.coffee

@@ -75,6 +75,9 @@ class NotificationsApi
       throw e if options.useAsyncApi
       console.log("Error sending status to notifications-api. Retrying via notifications-api-async")
       retryRequest()
+    .tapCatch (e) =>
+      console.log("Error sending status to notifications-api-async. Ignoring error.")
+      console.log(e)
     .catchReturn()
 
   _makeRequest: (body, { useAsyncApi } = {}) =>

src/processors/maxRetries.processor.coffee

@@ -15,6 +15,7 @@ module.exports =
         @_onMaxRetryExceeded_ notification, err
 
     _shouldRetry_: ({ meta: { dequeueCount = 0 } }, err) ->
+      console.log("dequeue count is #{dequeueCount} and max retries is #{@maxRetries}")
       dequeueCount < @maxRetries
 
     _onSuccess_: (notification, result) -> throw new Error "subclass responsability"

src/sources/aws.sqs.source.coffee

@@ -2,7 +2,7 @@ _ = require "lodash"
 
 module.exports =
   newNotification: ({ context, message }) ->
-    message: message
+    message: if(!_.isObject(message.Message)) then JSON.parse(message.Message) else message.Message
     meta: {
       insertionTime:  _.get(context, "bindingData.sentTimestamp"),
       dequeueCount: _.get(context, "bindingData.approximateReceiveCount"),