Module: Restalk::ResqueAdapter

Defined in:
lib/restalk.rb

Defined Under Namespace

Classes: RestalkResqueJob

Instance Method Summary collapse

Instance Method Details

#connected? ⇒ Boolean

Returns:

  • (Boolean) 


66
 
# File 'lib/restalk.rb', line 66

def connected?; true; end

#init(server = nil, queue = nil) ⇒ Object 



47
48
49
50
51
 
# File 'lib/restalk.rb', line 47

def init(server = nil, queue = nil)
  @queue = queue || ENV['RESQUE_QUEUE'] || 'restalk_queue'
  require 'resque'
  Resque.redis = server ||  ENV['REDIS'] || 'localhost:6379'
end

#pop ⇒ Object 



57
58
59
60
 
# File 'lib/restalk.rb', line 57

def pop
  data = Resque.pop @queue
  return RestalkResqueJob.new data['args'].first if data
end

#push(data) ⇒ Object 



53
54
55
 
# File 'lib/restalk.rb', line 53

def push(data)
  Resque.enqueue_to(@queue, RestalkResqueJob, data)
end

#stats ⇒ Object 



62
63
64
 
# File 'lib/restalk.rb', line 62

def stats
  Resque.info
end