This document describes the current stable version of Kombu (4.2). For development docs, go here.
Resource Management - kombu.resource
¶
Generic resource pool implementation.
-
class
kombu.resource.
Resource
(limit=None, preload=None, close_after_fork=None)[source]¶ Pool of resources.
-
exception
LimitExceeded
¶ Limit exceeded.
-
acquire
(block=False, timeout=None)[source]¶ Acquire resource.
Parameters: Raises: LimitExceeded
– if block is false and the limit has been exceeded.
-
close_after_fork
= False¶
-
force_close_all
()[source]¶ Close and remove all resources in the pool (also those in use).
Used to close resources from parent processes after fork (e.g. sockets/connections).
-
limit
¶
-
exception