diff --git a/packages/domain-events-infra/src/Infra/SQS/SQSDomainEventSubscriberFactory.ts b/packages/domain-events-infra/src/Infra/SQS/SQSDomainEventSubscriberFactory.ts index fe8d1936a..b8458cdd7 100644 --- a/packages/domain-events-infra/src/Infra/SQS/SQSDomainEventSubscriberFactory.ts +++ b/packages/domain-events-infra/src/Infra/SQS/SQSDomainEventSubscriberFactory.ts @@ -16,7 +16,7 @@ export class SQSDomainEventSubscriberFactory implements DomainEventSubscriberFac create(): DomainEventSubscriberInterface { const sqsConsumer = Consumer.create({ attributeNames: ['All'], - messageAttributeNames: ['compression', 'event'], + messageAttributeNames: ['All'], queueUrl: this.queueUrl, sqs: this.sqs, handleMessage: