Contents

namespace :simple_sqs do
  desc "Daemon that polls SQS"
  task :daemon => :environment do
    queue_url = ENV.fetch('SIMPLE_SQS_QUEUE_URL')

    Rails.logger.info "Simple SQS: started polling"

    worker = SimpleSqs::Worker.new(queue_url: queue_url)
    worker.start
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
simple_sqs-0.1.2	lib/tasks/simple_sqs.rake