class WorkflowRb::SingleNodeQueueProvider
Public Class Methods
new()
click to toggle source
# File lib/workflow_rb/services/single_node_queue_provider.rb, line 6 def initialize @process_queue = Queue.new @publish_queue = Queue.new end
Public Instance Methods
dequeue_for_processing()
click to toggle source
# File lib/workflow_rb/services/single_node_queue_provider.rb, line 15 def dequeue_for_processing begin return @process_queue.pop(true) rescue return nil end end
dequeue_for_publish()
click to toggle source
# File lib/workflow_rb/services/single_node_queue_provider.rb, line 27 def dequeue_for_publish begin return @publish_queue.pop(true) rescue return nil end end
queue_for_processing(id)
click to toggle source
# File lib/workflow_rb/services/single_node_queue_provider.rb, line 11 def queue_for_processing(id) @process_queue << id end
queue_for_publish(pub)
click to toggle source
# File lib/workflow_rb/services/single_node_queue_provider.rb, line 23 def queue_for_publish(pub) @publish_queue << pub end