create.js

const { SQS, listParams, createParams, msgParams, receiveParam, QUEUE_URL} = require('./util.js');

module.exports = {
    listSQS: async () => {
        SQS.listQueues(listParams, function(err, data) {
            if (err) {
              console.log("Error", err);
            } else {
              console.log("Success", data.QueueUrls);
            }
        });
    },

    createSqsQueue: async () => {
        SQS.createQueue(createParams, function(err, data) {
            if (err) {
              console.log("Error", err);
            } else {
              console.log("Success", data.QueueUrl);
            }
        });
    },

    sendMessage: async (msg) => {
        SQS.sendMessage(msgParams(msg), function(err, data) {
            if (err) {
              console.log("Error", err);
            } else {
              console.log("Success", data.MessageId);
            }
        });
    },
    getMessage: async () => {
        SQS.receiveMessage(receiveParam, function(err, data) {
            if (err) {
              console.log("Receive Error", err);
            } else if (data.Messages) {
              console.log('-----Message------');
              console.log(data.Messages);
              console.log('-----Message End------');
              var deleteParams = {
                QueueUrl: QUEUE_URL,
                ReceiptHandle: data.Messages[0].ReceiptHandle
              };
              SQS.deleteMessage(deleteParams, function(err, data) {
                if (err) {
                  console.log("Delete Error", err);
                } else {
                  console.log("Message Deleted", data);
                }
              });
            }
          });
    }

}