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
      begin
        job = beanstalk.reserve
        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

      begin
        job.delete
      rescue Exception => ex
        Rails.logger.error "XapianDb beanstalk worker: could delete job #{job.body} (#{ex})"
      end

    end

  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
xapian_db-0.5.10	tasks/beanstalk_worker.rake