Module: Esse::AsyncIndexing::JobsInterceptorAdapter

Defined in:
lib/esse/async_indexing/testing.rb

Instance Method Summary collapse

Instance Method Details

#push ⇒ Object 



61
62
63
64
65
66
67
68
69
70
71
72
73
74
 
# File 'lib/esse/async_indexing/testing.rb', line 61

def push
  return super unless Esse::AsyncIndexing::Testing.enabled?

  normalize_before_push
  test_payload = @payload.dup
  if @payload["jobtype"]
    test_payload["service"] = "faktory"
    test_payload["__class_name__"] = @payload["jobtype"]
  else
    test_payload["service"] = "sidekiq"
    test_payload["__class_name__"] = @payload["class"]
  end
  Esse::AsyncIndexing::Jobs.push(test_payload)
end