class Freddy::RequestManager
Public Class Methods
Source
# File lib/freddy/request_manager.rb, line 5 def initialize(logger) @requests = {} @logger = logger end
Public Instance Methods
Source
# File lib/freddy/request_manager.rb, line 22 def delete(correlation_id) @requests.delete(correlation_id) end
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
Source
# File lib/freddy/request_manager.rb, line 18 def store(correlation_id, opts) @requests[correlation_id] = opts end