Sha256: 57f1c8b0d550138ed8ac3e5c5ae23f5aa0d01364eaaefbfdda78a79cf4a4c88a
Contents?: true
Size: 300 Bytes
Versions: 12
Compression:
Stored size: 300 Bytes
Contents
require 'sneakers'
require 'thread'
require 'redis'
redis_addr = compose_or_localhost("redis")
puts "REDIS is at #{redis_addr}"
$redis = Redis.new(:host => redis_addr)
class IntegrationWorker
include Sneakers::Worker
def work(msg)
$redis.incr(self.class.queue_name)
ack!
end
end
Version data entries
12 entries across 12 versions & 2 rubygems