class TrRMIte::Consumers::Progress
Public Class Methods
new(topic, registry_uri)
click to toggle source
Calls superclass method
TrRMIte::Consumer::new
# File lib/TrRMIte/consumers/progress.rb, line 7 def initialize(topic, registry_uri) super('PROGRESS_CONSUMER', topic, registry_uri) @processed_event_count = 0 @max_event_count = ENV['MAX_EVENT_COUNT'].to_i end
Private Instance Methods
process(event)
click to toggle source
# File lib/TrRMIte/consumers/progress.rb, line 16 def process event @progress_bar ||= if @max_event_count.zero? ProgressBar.create( total: nil, format: 'Count: %c |%B| %a' ) else ProgressBar.create( total: @max_event_count, format: 'Count: %c/%C(%p%%) |%B| %a %e' ) end @progress_bar.increment @stop_processing = (@processed_event_count += 1) == @max_event_count end