module RequestQueue

# File lib/request_queue.rb, line 27
def enqueue(message)
  if queue.nil?
    raise MissingQueueError, 'You need to wrap this call in RequestQueue.process {}'
  end

  queue << message
end

# File lib/request_queue.rb, line 35
def process(backend = :default)
  original_queue = self.queue
  self.queue = BACKENDS.fetch(backend).new
  result = yield if block_given?
  queue.process unless queue.nil?
  result
ensure
  self.queue = original_queue
end

# File lib/request_queue.rb, line 23
def queue
  RequestStore.store[:request_queue]
end

# File lib/request_queue.rb, line 19
def queue=(value)
  RequestStore.store[:request_queue] = value
end