Adjust limits (#403)

Author: kibertoad

docker-compose.yml

@@ -10,7 +10,7 @@ services:
     restart: on-failure
 
   localstack:
-    image: localstack/localstack:4.10.0
+    image: localstack/localstack:4.13.1
     network_mode: bridge
     hostname: localstack
     ports:

examples/sns-sqs/docker-compose.yml

@@ -1,7 +1,7 @@
 services:
 
   localstack:
-    image: localstack/localstack:4.0.2
+    image: localstack/localstack:4.13.1
     network_mode: bridge
     hostname: localstack
     ports:

packages/sqs/README.md

@@ -71,7 +71,7 @@ Publishers send messages to SQS queues. They handle:
 - Message validation against Zod schemas
 - Automatic serialization
 - Optional deduplication (preventing duplicate sends)
-- Optional payload offloading (for messages > 256KB)
+- Optional payload offloading (for messages > 1 MiB)
 - FIFO-specific concerns (MessageGroupId, MessageDeduplicationId)
 
 ### Consumers
@@ -380,7 +380,7 @@ When using `creationConfig`, the queue will be created automatically if it doesn
 
         // Other attributes
         DelaySeconds: '0',                 // Default delay for all messages
-        MaximumMessageSize: '262144',      // 256 KB (default maximum)
+        MaximumMessageSize: '1048576',      // 1 MiB (default maximum)
       },
       tags: {
         Environment: 'production',
@@ -457,7 +457,7 @@ When using `locatorConfig`, you connect to an existing queue without creating it
   // Optional - Payload Offloading
   payloadStoreConfig: {
     payloadStore: s3Store,             // S3-based payload store
-    maxPayloadSize: 256 * 1024,        // 256 KB
+    maxPayloadSize: 1024 * 1024,       // 1 MiB
   },
 
   // Optional - Deletion
@@ -755,7 +755,7 @@ Prevents processing the same message multiple times:
 
 ### Payload Offloading
 
-For messages larger than 256 KB, store the payload externally (e.g., S3):
+For messages larger than 1 MiB, store the payload externally (e.g., S3):
 
 ```typescript
 import { S3PayloadStore } from '@message-queue-toolkit/s3-payload-store'
@@ -769,15 +769,15 @@ const payloadStore = new S3PayloadStore({
 {
   payloadStoreConfig: {
     payloadStore,
-    maxPayloadSize: 256 * 1024,  // 256 KB threshold
+    maxPayloadSize: 1024 * 1024,  // 1 MiB threshold
   },
 }
 
 // Large message is automatically offloaded
 await publisher.publish({
   id: '123',
   messageType: 'document.processed',
-  largeData: hugeArrayOfData,  // If total size > 256 KB, stored in S3
+  largeData: hugeArrayOfData,  // If total size > 1 MiB, stored in S3
 })
 ```
 

packages/sqs/lib/sqs/AbstractSqsService.ts

@@ -9,7 +9,7 @@ import type { SQSMessage } from '../types/MessageTypes.ts'
 import { deleteSqs, initSqs } from '../utils/sqsInitter.ts'
 
 // https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/quotas-messages.html
-export const SQS_MESSAGE_MAX_SIZE = 256 * 1024 // 256KB
+export const SQS_MESSAGE_MAX_SIZE = 1024 * 1024 // 1 MiB
 export const SQS_RESOURCE_ANY = Symbol('any')
 export const SQS_RESOURCE_CURRENT_QUEUE = Symbol('current_queue')
 

packages/sqs/lib/utils/sqsUtils.ts

@@ -274,7 +274,7 @@ export async function deleteQueue(
 /**
  * Calculates the size of an outgoing SQS message.
  *
- * SQS imposes a 256 KB limit on the total size of a message, which includes both the message body and any metadata (attributes).
+ * SQS imposes a 1 MiB limit on the total size of a message, which includes both the message body and any metadata (attributes).
  * This function currently computes the size based solely on the message body, as no attributes are included at this time.
  * For future updates, if message attributes are added, their sizes should also be considered.
  *