require 'redis_watcher'
require 'resque-loner'
require 'resque-lock-timeout'

class PubsubListener < Resque::Plugins::Loner::UniqueJob
	extend Resque::Plugins::LockTimeout
	@queue = :long_queue
	@lock_timeout = 30

	def self.perform
			#heartbeat thread to refresh lock
			thread = Thread.new do
				while true do
					self.refresh_lock
					sleep 5
				end
			end

			Rails.logger.info "Got here"
			RedisClient.subscribe(self)


	end
end