I am trying to use the NPM package of SQS (https://github.com/mafintosh/sqs) which will allow me to push items to a queue for processing, however, I keep running into this error:
Error: could send http://sqs.us-east-1.amazonaws.comundefined?MessageBody=%7B%22email%22%3A%22dennismonsewicz%40gmail.com%22%2C%22custom_activity_node_id%22%3A1%2C%22campaign_id%22%3A222%7D&Action=SendMessage...
I'm just not sure why this is error'ing out...
Here is how I am calling to it:
cfg = require '../../config/config'
sqs = require 'sqs'
log = console.log
queue = sqs(
access: cfg.aws.access_key
secret: cfg.aws.secret
region: cfg.aws.region
)
router.post '/users/activities', (req, res, next) ->
obj =
user_id: req.body.user_id
email: req.body.email if not req.body.user_id
custom_activity_node_id: req.body.custom_activity_node_id
campaign_id: req.body.campaign_id
queue.push('user_activity', obj)