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