Sha256: 8fbbecff03c3e6e288da326d773ef39f4e1c756691a63ed58ebfb57a12ed57be
Contents?: true
Size: 1.13 KB
Versions: 9
Compression:
Stored size: 1.13 KB
Contents
# encoding: utf-8
# This rake task is built to run within a Rails application and is the
# backend worker to serialize the index updates to a xapian database.
# Remember to install beanstalkd and configure the beanstalk-client gem
# in your Gemfile
require "#{Rails.root}/config/environment"
require "xapian_db"
require 'yaml'
namespace :xapian_db do
DEPRECATION_WARNING = "beanstalk_worker.rake is deprecated, use script/beanstalk_worker instead"
desc DEPRECATION_WARNING
task :beanstalk_worker do
url = XapianDb::Config.beanstalk_daemon_url
beanstalk = Beanstalk::Pool.new([url])
worker = XapianDb::IndexWriters::BeanstalkWorker.new
puts DEPRECATION_WARNING
puts "XapianDb beanstalk worker is serving on #{url}..."
loop do
job = beanstalk.reserve
begin
params = YAML::load job.body
Rails.logger.info "XapianDb beanstalk worker: executing task #{params}"
task = params.delete :task
worker.send task, params
rescue Exception => ex
Rails.logger.error "XapianDb beanstalk worker: could not process #{job.body} (#{ex})"
end
job.delete
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems