Contents

class ThinkingSphinx::Deltas::SidekiqDelta::FlagAsDeletedJob
  include Sidekiq::Worker

  # Runs Sphinx's indexer tool to process the index. Currently assumes Sphinx
  # is running.
  sidekiq_options unique: true, retry: true, queue: 'ts_delta'

  def perform(index, document_id)
    ThinkingSphinx::Deltas::DeleteJob.new(index, document_id).perform
  rescue Mysql2::Error => error
    # This isn't vital, so don't raise the error
  end
end

ThinkingSphinx::Deltas::SidekiqDelta::JOB_TYPES <<
  ThinkingSphinx::Deltas::SidekiqDelta::FlagAsDeletedJob

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
ts-sidekiq-delta-0.2.0	lib/thinking_sphinx/deltas/sidekiq_delta/flag_as_deleted_job.rb