Skip to content

Keep receiving error when pushing to queue #14

Description

@dennismonsewicz

Here is the error I am getting:

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)

queue.pull 'user_activity', (data, callback)->
  log data
  callback()

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions