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