diff --git a/packages/sns/lib/sns/AbstractSnsPublisher.ts b/packages/sns/lib/sns/AbstractSnsPublisher.ts
index 24086ef9..bc2ed8f7 100644
--- a/packages/sns/lib/sns/AbstractSnsPublisher.ts
+++ b/packages/sns/lib/sns/AbstractSnsPublisher.ts
@@ -80,7 +80,7 @@ export abstract class AbstractSnsPublisher<MessagePayloadType extends object>
       this.handleMessageProcessed(parsedMessage, 'published')
     } catch (error) {
       const err = error as Error
-      this.handleError(err)
+      this.handleError(err, { message: JSON.stringify(message) })
       throw new InternalError({
         message: `Error while publishing to SNS: ${err.message}`,
         errorCode: 'SNS_PUBLISH_ERROR',
diff --git a/packages/sqs/lib/sqs/AbstractSqsConsumer.ts b/packages/sqs/lib/sqs/AbstractSqsConsumer.ts
index 838e4636..8aa6141e 100644
--- a/packages/sqs/lib/sqs/AbstractSqsConsumer.ts
+++ b/packages/sqs/lib/sqs/AbstractSqsConsumer.ts
@@ -218,7 +218,7 @@ export abstract class AbstractSqsConsumer<
           messageType,
         )
           .catch((err) => {
-            this.handleError(err)
+            this.handleError(err, { parsedMessage: JSON.stringify(parsedMessage) })
             // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
             return { error: err }
           })
@@ -358,7 +358,7 @@ export abstract class AbstractSqsConsumer<
   private tryToExtractId(message: SQSMessage): Either<'abort', string> {
     const resolveMessageResult = this.resolveMessage(message)
     if (isMessageError(resolveMessageResult.error)) {
-      this.handleError(resolveMessageResult.error)
+      this.handleError(resolveMessageResult.error, { message: message.Body })
       return ABORT_EARLY_EITHER
     }
     // Empty content for whatever reason
@@ -384,7 +384,7 @@ export abstract class AbstractSqsConsumer<
 
     const resolveMessageResult = this.resolveMessage(message)
     if (isMessageError(resolveMessageResult.error)) {
-      this.handleError(resolveMessageResult.error)
+      this.handleError(resolveMessageResult.error, { message: message.Body })
       return ABORT_EARLY_EITHER
     }
     // Empty content for whatever reason
@@ -396,7 +396,7 @@ export abstract class AbstractSqsConsumer<
       resolveMessageResult.result as MessagePayloadType,
     )
     if (resolveSchemaResult.error) {
-      this.handleError(resolveSchemaResult.error)
+      this.handleError(resolveSchemaResult.error, { message: message.Body })
       return ABORT_EARLY_EITHER
     }
 
@@ -406,7 +406,7 @@ export abstract class AbstractSqsConsumer<
       this.errorResolver,
     )
     if (isMessageError(deserializationResult.error)) {
-      this.handleError(deserializationResult.error)
+      this.handleError(deserializationResult.error, { message: message.Body })
       return ABORT_EARLY_EITHER
     }
 
diff --git a/packages/sqs/lib/sqs/AbstractSqsPublisher.ts b/packages/sqs/lib/sqs/AbstractSqsPublisher.ts
index ef3aa2da..c2d22b01 100644
--- a/packages/sqs/lib/sqs/AbstractSqsPublisher.ts
+++ b/packages/sqs/lib/sqs/AbstractSqsPublisher.ts
@@ -80,7 +80,7 @@ export abstract class AbstractSqsPublisher<MessagePayloadType extends object>
       this.handleMessageProcessed(parsedMessage, 'published')
     } catch (error) {
       const err = error as Error
-      this.handleError(err)
+      this.handleError(err, { message: JSON.stringify(message) })
       throw new InternalError({
         message: `Error while publishing to SQS: ${err.message}`,
         errorCode: 'SQS_PUBLISH_ERROR',