aws-sqs-stream
AWS SQS library written using node.js streams.
Usage: Library
var SqsStream = SqsStream;var MemoryStream = ;var AWS = ; var sqsOptions = "awsConfig": "accessKeyId": "STRING" "secretAccessKey": "STRING" "region": "us-east-1" "QueueUrl": "https://sqs.us-east-1.amazonaws.com/#######/STRING" "QueueOptions": "MaxNumberOfMessages": 10 "WaitTimeSeconds": 4 "VisibilityTimeout": 15 ; var readStream = sqsOptionsvar writeStream = objectMode: true ;var sqsClient = sqsOptionsawsConfig; readStream; writeStream; readStream;
Usage: Broadway/Mixdown plugin
var broadway = ;var MemoryStream = ;var SqsPlugin = SqsPlugin;var sqsOptions = "awsConfig": "accessKeyId": "STRING" "secretAccessKey": "STRING" "region": "us-east-1" "QueueUrl": "https://sqs.us-east-1.amazonaws.com/#######/STRING" "QueueOptions": "MaxNumberOfMessages": 10 "WaitTimeSeconds": 4 "VisibilityTimeout": 15 ; var app = plugins: ; // attach the broadway/mixdown pluginappplugins; // call init to setup the sqsClientappplugins;