Sha256: 9c092d5ea4963dd3646226ac753c669106da60dfbb0f27522ce8c9d6169137d1
Contents?: true
Size: 1.13 KB
Versions: 6
Compression:
Stored size: 1.13 KB
Contents
class Freddy
class RequestManager
def initialize(requests, logger)
@requests, @logger = requests, logger
end
def start
@timeout_thread = Thread.new do
while true do
clear_timeouts Time.now
sleep 0.05
end
end
end
def no_route(correlation_id)
if request = @requests[correlation_id]
@requests.delete correlation_id
request[:callback].call({error: 'Specified queue does not exist'}, nil)
end
end
private
def clear_timeouts(now)
@requests.each do |key, value|
timeout(key, value) if now > value[:timeout]
end
end
def timeout(correlation_id, request)
@requests.delete correlation_id
message = "Request #{correlation_id} timed out waiting response from #{request[:destination]} with timeout #{request[:timeout]}"
@logger.warn message
Freddy.notify 'RequestTimeout', message, request: correlation_id, destination: request[:destination], timeout: request[:timeout]
request[:callback].call({error: 'RequestTimeout', message: 'Timed out waiting for response'}, nil)
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems