Sha256: 10f6065cf890970bb86c4a65575f86f5a2956260aae4354552ca6319e3bfea71
Contents?: true
Size: 202 Bytes
Versions: 6
Compression:
Stored size: 202 Bytes
Contents
require 'sneakers'
require 'thread'
require 'redis'
$redis = Redis.new
class IntegrationWorker
include Sneakers::Worker
def work(msg)
$redis.incr(self.class.queue_name)
ack!
end
end
Version data entries
6 entries across 6 versions & 1 rubygems