How to Receive a Message from AWS SQS with Node.js

const AWS = require('aws-sdk');

AWS.config.update({ credentials: new AWS.CognitoIdentityCredentials({ IdentityPoolId: 'identityPoolId', accessKeyId: 'accessKeyId', secretAccessKey: 'secretAccessKey' }), region: 'regionName' });

const sqs = new AWS.SQS();

sqs.receiveMessage({ QueueUrl: 'queueUrl' }, (err, res) => {
    console.log(res.Messages[0].Body);

    sqs.deleteMessage({ QueueUrl: 'queueUrl', ReceiptHandle: res.Messages[0].ReceiptHandle }, (err, res) => {});
  });

Leave a Reply

Fill in your details below or click an icon to log in:

WordPress.com Logo

You are commenting using your WordPress.com account. Log Out / Change )

Twitter picture

You are commenting using your Twitter account. Log Out / Change )

Facebook photo

You are commenting using your Facebook account. Log Out / Change )

Google+ photo

You are commenting using your Google+ account. Log Out / Change )

Connecting to %s