@monmedx/monmedx-pubsub v2.1.0

commons-service

const {sqsQueue} = require('pubsub-service');

#Optional sqsQueue.configUpdate({});

#Receive sqs Message config sqsQueue.start([{'auditQueue':"shipment"}],app);

#Receive sqs Message Example app.on('sqsEvent', (eventName,event_data) => { console.log('sqsEvent :',eventName,event_data); });

const {sqsQueue} = require('commons-service');

#send sqs Message config app.on('sendSqsEvent', (topic_name, data) => { snsTopic.sendSnsMessage(topic_name,data); });

permissions Required

SNS : createTopic,listTopics,subscribe,listSubscriptionsByTopic

SQS : createQueue,getQueueAttributes,setQueueAttributes,getQueueUrl,sendmessage,receivemessage,deleteMessage