lib/worker.js
function Worker (opts) {
  _.extend(this, {
    grabber: null,
    saver: null,
    logger: require(config.get('logger'))
  }, opts)

  this.sqs = new aws.SQS({
    accessKeyId: config.get('awsKey'),
    secretAccessKey: config.get('awsSecret'),
    region: config.get('awsRegion')
  })

  config.set('sqsQueueUrl', this.sqs.endpoint.protocol + '//' + this.sqs.endpoint.hostname + '/' + config.get('sqsQueue'))
}
function Worker (opts) {
  _.extend(this, {
    grabber: null,
    saver: null,
    logger: require(config.get('logger'))
  }, opts)

  this.sqs = new aws.SQS({
    accessKeyId: config.get('awsKey'),
    secretAccessKey: config.get('awsSecret'),
    region: config.get('awsRegion')
  })

  config.set('sqsQueueUrl', this.sqs.endpoint.protocol + '//' + this.sqs.endpoint.hostname + '/' + config.get('sqsQueue'))
}
function Worker ( opts ) { _ . extend ( this , { grabber : null , saver : null , logger : require ( config . get ( 'logger' ) ) } , opts ) this . sqs = new aws . SQS ( { accessKeyId : config . get ( 'awsKey' ) , secretAccessKey : config . get ( 'awsSecret' ) , region : config . get ( 'awsRegion' ) } ) config . set ( 'sqsQueueUrl' , this . sqs . endpoint . protocol + '//' + this . sqs . endpoint . hostname + '/' + config . get ( 'sqsQueue' ) ) }
Initialize the Worker

@param object opts Worker configuration. Optional.
Initialize the Worker