class Freddy::RequestManager

Public Class Methods

new(logger) click to toggle source
# File lib/freddy/request_manager.rb, line 5
def initialize(logger)
  @requests = {}
  @logger = logger
end

Public Instance Methods

delete(correlation_id) click to toggle source
# File lib/freddy/request_manager.rb, line 22
def delete(correlation_id)
  @requests.delete(correlation_id)
end
no_route(correlation_id) click to toggle source
# File lib/freddy/request_manager.rb, line 10
def no_route(correlation_id)
  request = @requests[correlation_id]
  return unless request

  delete(correlation_id)
  request[:callback].call({ error: 'Specified queue does not exist' }, nil)
end
store(correlation_id, opts) click to toggle source
# File lib/freddy/request_manager.rb, line 18
def store(correlation_id, opts)
  @requests[correlation_id] = opts
end