Contents

require_relative "../../../spec/support/file_helper"

class TestWorker
  QUEUE_NAME  = :sneakers_queue
  ROUTING_KEY  = :sneakers_routing_key
  VERIFICATION_FILE = "tmp/sneakers.verified".freeze

  include Sneakers::Worker
  include FileHelper

  from_queue QUEUE_NAME, routing_key: ROUTING_KEY

  def work(_message)
    create_file(VERIFICATION_FILE)
    ack!
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
sapience-0.2.7	test_app/app/workers/test_worker.rb
sapience-0.2.6	test_app/app/workers/test_worker.rb
sapience-0.2.5	test_app/app/workers/test_worker.rb