const exampleProducerFunctionForStandardQueue = async () => {
  const producer = Producer.create({
  queueUrl: config.queueUrl,
  region: config.region
});

// send simple messages to the queue
await producer.send(['msg1', 'msg2']);
}

const exampleProducerFunctionForFIFOQueue = async () => {
const producer = Producer.create({
  queueUrl: config.queueUrl,
  region: config.region
});
await producer.send({
  id: "testId",
  body: 'Hello world from our FIFO queue!' + new Date().toISOString(),
  groupId: 'group1234',
  // generate md5 hash of body (for deduplication)
  deduplicationId: crypto.createHash('md5').update(body).digest('hex')  
});
}

const app = Consumer.create({
queueUrl: config.queueUrl,
region: config.region,
handleMessage: async (message: { MessageId: string, ReceiptHandle: string, Body: string }) => {
  console.log(`{${message.MessageId}} ${message.Body} is received!`)
  // Super Awesome Messaging handling logic 🚀
},
sqs: new AWS.SQS()
});

app.on('error', (err) => {
console.error(err.message);
});

app.on('processing_error', (err) => {
console.error(err.message);
});

app.on('timeout_error', (err) => {
console.error(err.message);
});

app.start();