Yohohohohohooho | Sanrei Aya
Sanrei Aya


Server : LiteSpeed
System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64
User : elvh3918 ( 1528)
PHP Version : 8.2.31
Disable Function : mail
Directory :  /proc/self/root/usr/local/lib/python3.9/site-packages/kombu/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Current File : //proc/self/root/usr/local/lib/python3.9/site-packages/kombu/__pycache__/exceptions.cpython-39.pyc
a

��Sh�@svdZddlmZddlmZddlmZddlm	Z	m
Z
ddlmZm
Z
mZe	r\ddlmZdZe
d	ed
�Zd/dd	d
d	d�dd�ZGdd�de�ZGdd�de�ZGdd�de�ZGdd�de�ZGdd�de�ZGdd�de�ZGdd�de�ZGdd �d e�ZGd!d"�d"e�ZGd#d$�d$e�ZGd%d&�d&e�Z Gd'd(�d(e�Z!Gd)d*�d*e!�Z"Gd+d,�d,e
�Z#Gd-d.�d.e�Z$dS)0zExceptions.�)�annotations)�timeout)�
TracebackType)�
TYPE_CHECKING�TypeVar)�ChannelError�ConnectionError�
ResourceError)�Response)�reraise�
KombuError�OperationalError�
NotBoundError�MessageStateError�TimeoutError�
LimitExceeded�ConnectionLimitExceeded�ChannelLimitExceededrr�VersionMismatch�SerializerNotInstalledr	�SerializationError�EncodeError�DecodeError�	HttpError�InconsistencyError�BaseExceptionType)�boundNztype[BaseExceptionType]zTracebackType | None)�tp�value�tb�returncCs|j|ur|�|��|�dS)zReraise exception.N)�
__traceback__�with_traceback)rrr�r#�:/usr/local/lib/python3.9/site-packages/kombu/exceptions.pyrs

rc@seZdZdZdS)rz)Common subclass for all Kombu exceptions.N��__name__�
__module__�__qualname__�__doc__r#r#r#r$r&src@seZdZdZdS)r
z/Recoverable message transport connection error.Nr%r#r#r#r$r
*sr
c@seZdZdZdS)rz(Failed to serialize/deserialize content.Nr%r#r#r#r$r.src@seZdZdZdS)rzCannot encode object.Nr%r#r#r#r$r2src@seZdZdZdS)rzCannot decode object.Nr%r#r#r#r$r6src@seZdZdZdS)rz:Trying to call channel dependent method on unbound entity.Nr%r#r#r#r$r:src@seZdZdZdS)rz*The message has already been acknowledged.Nr%r#r#r#r$r>src@seZdZdZdS)rzLimit exceeded.Nr%r#r#r#r$rBsrc@seZdZdZdS)rz4Maximum number of simultaneous connections exceeded.Nr%r#r#r#r$rFsrc@seZdZdZdS)rz1Maximum number of simultaneous channels exceeded.Nr%r#r#r#r$rJsrc@seZdZdZdS)rz$Library dependency version mismatch.Nr%r#r#r#r$rNsrc@seZdZdZdS)rz>Support for the requested serialization type is not installed.Nr%r#r#r#r$rRsrc@seZdZdZdS)�ContentDisallowedz*Consumer does not allow this content-type.Nr%r#r#r#r$r*Vsr*c@seZdZdZdS)rz�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$rZsrcs<eZdZdZdddddd��fdd	�
Zd
d�dd
�Z�ZS)rzHTTP Client Error.N�intz
str | NonezResponse | None�None)�code�message�responser cs&||_||_||_t��|||�dS)N)r-r.r/�super�__init__)�selfr-r.r/��	__class__r#r$r1dszHttpError.__init__�str)r cCs
d�|�S)NzHTTP {0.code}: {0.message})�format)r2r#r#r$�__str__oszHttpError.__str__)NN)r&r'r(r)r1r7�
__classcell__r#r#r3r$ras
�r)N)%r)�
__future__r�socketrr�typesr�typingrrZamqprrr	Zkombu.asynchronous.httpr
�__all__�
BaseExceptionrr�	Exceptionrr
rrrrrrrrrrr*rrr#r#r#r$�<module>s4
�

Yohohohohohooho | Sanrei Aya