class Reservation

A reserved processing permit and response exchange.

Definitions

def initialize(backend, queue_name)

Signature

parameter backend Backend

The reserved backend.

parameter queue_name Symbol

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