
    ^f                    0   d Z ddlmZ ddlmZ ddlmZ ddlm	Z	m
Z
 ddlmZmZmZ e	rddlmZ dZ e
d	e
          Z	 d1d2dZ G d de          Z G d de          Z G d de          Z G d de          Z G d de          Z G d de          Z G d d e          Z G d! d"e          Z G d# d$e          Z G d% d&e          Z G d' d(e          Z  G d) d*e          Z! G d+ d,e!          Z" G d- d.e          Z# G d/ d0e          Z$dS )3z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)boundNtptype[BaseExceptionType]valuetbTracebackType | Nonereturnc                B    |j         |ur|                    |          |)zReraise exception.)__traceback__with_traceback)r   r    r!   s      B/var/www/html/env/lib/python3.11/site-packages/kombu/exceptions.pyr   r      s+     "$$""2&&&
K    c                      e Zd ZdZdS )r   z)Common subclass for all Kombu exceptions.N__name__
__module____qualname____doc__ r(   r'   r   r   &   s        3333r(   r   c                      e Zd ZdZdS )r   z/Recoverable message transport connection error.Nr*   r/   r(   r'   r   r   *   s        9999r(   r   c                      e Zd ZdZdS )r   z(Failed to serialize/deserialize content.Nr*   r/   r(   r'   r   r   .   s        2222r(   r   c                      e Zd ZdZdS )r   zCannot encode object.Nr*   r/   r(   r'   r   r   2           r(   r   c                      e Zd ZdZdS )r   zCannot decode object.Nr*   r/   r(   r'   r   r   6   r3   r(   r   c                      e Zd ZdZdS )r   z:Trying to call channel dependent method on unbound entity.Nr*   r/   r(   r'   r   r   :   s        DDDDr(   r   c                      e Zd ZdZdS )r   z*The message has already been acknowledged.Nr*   r/   r(   r'   r   r   >           4444r(   r   c                      e Zd ZdZdS )r   zLimit exceeded.Nr*   r/   r(   r'   r   r   B   s        r(   r   c                      e Zd ZdZdS )r   z4Maximum number of simultaneous connections exceeded.Nr*   r/   r(   r'   r   r   F   s        >>>>r(   r   c                      e Zd ZdZdS )r   z1Maximum number of simultaneous channels exceeded.Nr*   r/   r(   r'   r   r   J   s        ;;;;r(   r   c                      e Zd ZdZdS )r   z$Library dependency version mismatch.Nr*   r/   r(   r'   r   r   N   s        ....r(   r   c                      e Zd ZdZdS )r   z>Support for the requested serialization type is not installed.Nr*   r/   r(   r'   r   r   R   s        HHHHr(   r   c                      e Zd ZdZdS )ContentDisallowedz*Consumer does not allow this content-type.Nr*   r/   r(   r'   r>   r>   V   r7   r(   r>   c                      e Zd ZdZdS )r   zData 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(   r   c                  2     e Zd ZdZ	 	 dd fdZddZ xZS )r   zHTTP Client Error.Ncodeintmessage
str | NoneresponseResponse | Noner#   Nonec                x    || _         || _        || _        t                                          |||           d S N)rA   rC   rE   super__init__)selfrA   rC   rE   	__class__s       r'   rK   zHttpError.__init__d   s<     	 w11111r(   strc                ,    d                     |           S )NzHTTP {0.code}: {0.message})format)rL   s    r'   __str__zHttpError.__str__o   s    +224888r(   )NN)rA   rB   rC   rD   rE   rF   r#   rG   )r#   rN   )r+   r,   r-   r.   rK   rQ   __classcell__)rM   s   @r'   r   r   a   sd        
 #$(		2 	2 	2 	2 	2 	2 	29 9 9 9 9 9 9 9r(   r   rI   )r   r   r    r   r!   r"   r#   r   )%r.   
__future__r   socketr   r   typesr   typingr   r   amqpr   r	   r
   kombu.asynchronous.httpr   __all__BaseExceptionr   r   	Exceptionr   r   r   r   r   r   r   r   r   r   r   r   r>   r   r   r/   r(   r'   <module>r\      sa     " " " " " " * * * * * *       ) ) ) ) ) ) ) ) = = = = = = = = = = 1000000 G/}EEE   $    4 4 4 4 4 4 4 4: : : : :z : : :3 3 3 3 3 3 3 3         $               $      E E E E EJ E E E5 5 5 5 5
 5 5 5    J   ? ? ? ? ?m ? ? ?< < < < <= < < </ / / / /j / / /I I I I IZ I I I5 5 5 5 5. 5 5 5       9 9 9 9 9	 9 9 9 9 9r(   