Module: Resque

Defined in:
lib/resque-analytics/server.rb,
lib/resque/plugins/analytics.rb

Defined Under Namespace

Modules: Plugins Classes: Job

Instance Method Summary collapse

Instance Method Details

#push(queue, item) ⇒ Object

Override Resque’s push method to add a timestemp to each enqueued item



5
6
7
8
9
10
11
12
13
14
 
# File 'lib/resque/plugins/analytics.rb', line 5

def push(queue, item)
  tries ||= 3
  item['analytics_timestamp'] = Time.now if item.is_a?(Hash) && !Resque::Plugins::Analytics.ignore_classes.include?(item[:class])
  redis.pipelined do
    watch_queue(queue)
    redis.rpush "queue:#{queue}", encode(item)
  end
rescue Redis::TimeoutError, Redis::CannotConnectError
  retry if (tries -= 1).nonzero?
end