sqs-producer.js

SQS - producer node.js

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

AWS.config.update({
  region: 'us-east-1'
});

const sqs = new AWS.SQS({
   apiVersion: '2012-11-05'
});

const queueUrl = "https://sqs.us-east-1.amazonaws.com/0000000000000000000000/kyc-event-sqs";

const publish = (txt, delay)=>{

  const orderData = {
    'value':txt,
    'userEmail': 'damian.cipolat@gmail.com',
    'itemName': 'Test-name',
    'itemPrice': '10',
    'itemsQuantity': '10'
  };

  const sqsOrderData = {
    MessageAttributes: {
      "ovni": {
        DataType: "String",
        StringValue: 'ALF'
      },
    },
    MessageBody: JSON.stringify(orderData),
    QueueUrl: queueUrl,
    DelaySeconds: delay
  };

  return sqs.sendMessage(sqsOrderData).promise();

};

const send = async ()=>{

  await publish('AAAAA',0);
  await publish('BBBBB',20);
  await publish('CCCCC',0);

}

send()
  .then(a=>console.log('then',a))
  .catch(e=>console.error('error',e));