class Reservation
A reserved processing permit and response exchange.
Definitions
def initialize(backend, queue_name)
Signature
-
parameter
backendBackend The reserved backend.
-
parameter
queue_nameSymbol The queue consuming the permit.
Implementation
def initialize(backend, queue_name)
@backend = backend
@queue_name = queue_name
end
def processed
Release the processing permit after response headers arrive.
Implementation
def processed
@backend.processed(@queue_name)
end
def failed
Release the processing permit and exchange after an upstream failure.
Implementation
def failed
@backend.failed(@queue_name)
end
def release
Release the response exchange after its body closes.
Implementation
def release
@backend.release
end