Class: Worker

Inherits:
Runnable show all
Defined in:
lib/s3-object-processor.rb

Instance Method Summary collapse

Methods inherited from Runnable

#join, #on_finish

Constructor Details

#initialize(no, key_queue, &process_key) ⇒ Worker

Returns a new instance of Worker.



92
93
94
95
96
 
# File 'lib/s3-object-processor.rb', line 92

def initialize(no, key_queue, &process_key)
  @no = no
  @key_queue = key_queue
  @process_key = process_key
end

Instance Method Details

#on_error(&callback) ⇒ Object 



98
99
100
101
 
# File 'lib/s3-object-processor.rb', line 98

def on_error(&callback)
  @on_error = callback
  self
end

#run ⇒ Object 



103
104
105
106
107
108
109
110
111
112
113
 
# File 'lib/s3-object-processor.rb', line 103

def run
  super do
    until (key = @key_queue.pop) == :end
      begin
        @process_key.call(key)
      rescue => error
        @on_error.call(key, error) if @on_error
      end
    end
  end
end