Class: Freddy::RequestManager

Inherits:
Object
  • Object
show all
Defined in:
lib/freddy/request_manager.rb

Instance Method Summary collapse

Constructor Details

#initialize(logger) ⇒ RequestManager

Returns a new instance of RequestManager.



5
6
7
8
 
# File 'lib/freddy/request_manager.rb', line 5

def initialize(logger)
  @requests = {}
  @logger = logger
end

Instance Method Details

#delete(correlation_id) ⇒ Object 



22
23
24
 
# File 'lib/freddy/request_manager.rb', line 22

def delete(correlation_id)
  @requests.delete(correlation_id)
end

#no_route(correlation_id) ⇒ Object 



10
11
12
13
14
15
16
 
# 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) ⇒ Object 



18
19
20
 
# File 'lib/freddy/request_manager.rb', line 18

def store(correlation_id, opts)
  @requests[correlation_id] = opts
end