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