File: //proc/self/root/usr/local/lib/python3.9/site-packages/kombu/__pycache__/exceptions.cpython-39.pyc
a
X>h � @ sv d Z ddlmZ ddlmZ ddlmZ ddlm Z m
Z
ddl m Z m
Z
mZ e r\ddlmZ dZe
d ed
�Zd/d d d
d d�dd�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd � d e�ZG d d � d e�Z G d d � d e�Z G d!d"� d"e �Z G d#d$� d$e �Z G d%d&� d&e�Z G d'd(� d(e�Z!G d)d*� d*e!�Z"G d+d,� d,e
�Z#G d-d.� d.e�Z$d S )0z Exceptions.� )� annotations)�timeout)�
TracebackType)�
TYPE_CHECKING�TypeVar)� ChannelError�ConnectionError�
ResourceError)�Response)�reraise�
KombuError�OperationalError�
NotBoundError�MessageStateError� TimeoutError�
LimitExceeded�ConnectionLimitExceeded�ChannelLimitExceededr r �VersionMismatch�SerializerNotInstalledr �SerializationError� EncodeError� DecodeError� HttpError�InconsistencyError�BaseExceptionType)�boundNztype[BaseExceptionType]zTracebackType | None)�tp�value�tb�returnc C s |j |ur|�|��|�dS )zReraise exception.N)�
__traceback__�with_traceback)r r r � r# �:/usr/local/lib/python3.9/site-packages/kombu/exceptions.pyr s
r c @ s e Zd ZdZdS )r z)Common subclass for all Kombu exceptions.N��__name__�
__module__� __qualname__�__doc__r# r# r# r$ r & s r c @ s e Zd ZdZdS )r
z/Recoverable message transport connection error.Nr% r# r# r# r$ r
* s r
c @ s e Zd ZdZdS )r z(Failed to serialize/deserialize content.Nr% r# r# r# r$ r . s r c @ s e Zd ZdZdS )r zCannot encode object.Nr% r# r# r# r$ r 2 s r c @ s e Zd ZdZdS )r zCannot decode object.Nr% r# r# r# r$ r 6 s r c @ s e Zd ZdZdS )r z:Trying to call channel dependent method on unbound entity.Nr% r# r# r# r$ r : s r c @ s e Zd ZdZdS )r z*The message has already been acknowledged.Nr% r# r# r# r$ r > s r c @ s e Zd ZdZdS )r zLimit exceeded.Nr% r# r# r# r$ r B s r c @ s e Zd ZdZdS )r z4Maximum number of simultaneous connections exceeded.Nr% r# r# r# r$ r F s r c @ s e Zd ZdZdS )r z1Maximum number of simultaneous channels exceeded.Nr% r# r# r# r$ r J s r c @ s e Zd ZdZdS )r z$Library dependency version mismatch.Nr% r# r# r# r$ r N s r c @ s e Zd ZdZdS )r z>Support for the requested serialization type is not installed.Nr% r# r# r# r$ r R s r c @ s e Zd ZdZdS )�ContentDisallowedz*Consumer does not allow this content-type.Nr% r# r# r# r$ r* V s r* c @ s e Zd ZdZdS )r z�Data or environment has been found to be inconsistent.
Depending on the cause it may be possible to retry the operation.
Nr% r# r# r# r$ r Z s r c s< e Zd ZdZdddddd�� fdd �
Zd
d �d d
�Z� ZS )r zHTTP Client Error.N�intz
str | NonezResponse | None�None)�code�message�responser c s& || _ || _|| _t� �|||� d S )N)r- r. r/ �super�__init__)�selfr- r. r/ �� __class__r# r$ r1 d s zHttpError.__init__�str)r c C s
d� | �S )NzHTTP {0.code}: {0.message})�format)r2 r# r# r$ �__str__o s zHttpError.__str__)NN)r& r' r( r) r1 r7 �
__classcell__r# r# r3 r$ r a s
� r )N)%r) �
__future__r �socketr r �typesr �typingr r Zamqpr r r Zkombu.asynchronous.httpr
�__all__�
BaseExceptionr r � Exceptionr r
r r r r r r r r r r r* r r r# r# r# r$ �<module> s4
�