class Freddy::RequestManager

Public Class Methods

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

Public Instance Methods

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