Module: IronCuke::Queue

Included in:
IronCuke
Defined in:
lib/iron_cuke/queue.rb

Instance Method Summary collapse

Instance Method Details

#clear_queue ⇒ Object 



26
27
28
 
# File 'lib/iron_cuke/queue.rb', line 26

def clear_queue
	worker_queue.clear
end

#queue(worker, options) ⇒ Object

Raises:

  • (NotImplementedError) 


15
16
17
18
19
20
21
22
23
24
 
# File 'lib/iron_cuke/queue.rb', line 15

def queue(worker, options)
	options = {:priority => 0}.merge(options)
	raise NotImplementedError unless options[:priority].between?(0,2)

	worker_queue[options[:priority]] ||= []
	item = IronCuke::QueueItem.new(worker, options)
	worker_queue[options[:priority]] << item
	worker.task_id = item.id
	response = IronCuke::Queue.create_response(item)
end

#queued(priority = 0) ⇒ Object

Raises:

  • (ArgumentError) 


6
7
8
9
10
11
12
13
 
# File 'lib/iron_cuke/queue.rb', line 6

def queued(priority = 0)
	raise ArgumentError unless priority.between?(0,2)
	worker_queue.select{|p, workers| p >= priority}.values.map { |p| 
		p.map { |data| 
			data.worker 
		} 
	}.flatten
end