@aws-sdk/middleware-sdk-sqs

What is @aws-sdk/middleware-sdk-sqs?

@aws-sdk/middleware-sdk-sqs is a middleware package for the AWS SDK for JavaScript (v3) that provides specialized middleware for Amazon Simple Queue Service (SQS). It helps in handling SQS-specific tasks such as message deduplication, message attribute handling, and more.

What are @aws-sdk/middleware-sdk-sqs's main functionalities?

Message Deduplication

This feature allows you to send messages with deduplication enabled, which is useful for FIFO (First-In-First-Out) queues. The middleware automatically handles deduplication logic.

const { SQSClient, SendMessageCommand } = require('@aws-sdk/client-sqs');
const { applyMiddleware } = require('@aws-sdk/middleware-sdk-sqs');

const client = new SQSClient({ region: 'us-east-1' });
applyMiddleware(client);

const params = {
  QueueUrl: 'https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue',
  MessageBody: 'Hello, world!',
  MessageDeduplicationId: 'unique-id-123',
  MessageGroupId: 'group-id-1'
};

const command = new SendMessageCommand(params);
client.send(command).then((data) => {
  console.log('Message sent:', data);
}).catch((error) => {
  console.error('Error sending message:', error);
});

Message Attribute Handling

This feature allows you to send messages with custom attributes. The middleware helps in managing and sending these attributes along with the message.

const { SQSClient, SendMessageCommand } = require('@aws-sdk/client-sqs');
const { applyMiddleware } = require('@aws-sdk/middleware-sdk-sqs');

const client = new SQSClient({ region: 'us-east-1' });
applyMiddleware(client);

const params = {
  QueueUrl: 'https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue',
  MessageBody: 'Hello, world!',
  MessageAttributes: {
    'AttributeOne': {
      DataType: 'String',
      StringValue: 'ValueOne'
    },
    'AttributeTwo': {
      DataType: 'Number',
      StringValue: '123'
    }
  }
};

const command = new SendMessageCommand(params);
client.send(command).then((data) => {
  console.log('Message sent with attributes:', data);
}).catch((error) => {
  console.error('Error sending message:', error);
});

Other packages similar to @aws-sdk/middleware-sdk-sqs

@aws-sdk/client-sqs

@aws-sdk/client-sqs is the main client package for interacting with Amazon SQS. It provides a comprehensive set of methods for sending, receiving, and managing SQS messages and queues. While @aws-sdk/middleware-sdk-sqs focuses on middleware functionalities, @aws-sdk/client-sqs provides the core functionalities for SQS operations.

sqs-consumer

sqs-consumer is a lightweight library for building SQS-based applications. It simplifies the process of consuming messages from SQS queues and provides features like automatic polling and error handling. Unlike @aws-sdk/middleware-sdk-sqs, which is middleware for the AWS SDK, sqs-consumer is a standalone library focused on message consumption.

sqs-producer

sqs-producer is a library for sending messages to SQS queues. It provides a simple API for creating and sending messages. While @aws-sdk/middleware-sdk-sqs offers middleware functionalities for the AWS SDK, sqs-producer is a standalone library focused on message production.

README

@aws-sdk/middleware-sdk-sqs

Changelog

3.306.0 (2023-04-04)

Bug Fixes

• types: node-http-handler type imports and @aws-sdk/types exports (#4610) (8ee06d4)

Features

• client-amplifyuibuilder: Support StorageField and custom displays for data-bound options in form builder. Support non-string operands for predicates in collections. Support choosing client to get token from. (b24e527)
• client-dataexchange: This release updates the value of MaxResults. (b795ebc)
• client-ec2: C6in, M6in, M6idn, R6in and R6idn bare metal instances are powered by 3rd Generation Intel Xeon Scalable processors and offer up to 200 Gbps of network bandwidth. (01bddbc)
• client-elastic-inference: Updated public documentation for the Describe and Tagging APIs. (e28258e)
• client-rekognitionstreaming: update model (#4609) (ddb0c5d)
• client-sagemaker-runtime: Amazon SageMaker Asynchronous Inference now provides customers a FailureLocation as a response parameter in InvokeEndpointAsync API to capture the model failure responses. (62f9c4d)
• client-sagemaker: Amazon SageMaker Asynchronous Inference now allows customer's to receive failure model responses in S3 and receive success/failure model responses in SNS notifications. (bbc2fd1)
• client-wafv2: This release rolls back association config feature for webACLs that protect CloudFront protections. (f96b649)
• clients: update client endpoints as of 2023-04-04 (597085d)